相关疑难解决方法(0)

Flux.create和之间有什么区别Flux.generate？我正在寻找 - 理想情况下使用示例用例 - 来了解何时应该使用其中一个.

• 当我的服务启动时，我想构建一个简单的管道。
• 我想隔离 Flux 接收器或处理器来发出事件。
• 事件将来自多个线程，应该根据管道的subscribeOn()规范进行处理，但一切似乎都在main线程上运行。
• 最好的方法是什么？我在下面附上了我的尝试。
• （我正在使用 reactor-core v3.2.8.RELEASE。）

import org.junit.jupiter.api.Test;

import reactor.core.publisher.DirectProcessor;
import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxProcessor;
import reactor.core.publisher.FluxSink;
import reactor.core.scheduler.Schedulers;

/**
 * I want to construct my React pipelines during creation,
 * then emit events over the lifetime of my services.
 */
public class React1Test
{
    /**
     * Attempt 1 - use a DirectProcessor and send items to it.
     * Doesn't work though - seems to always run on the main thread.
     */
    @Test
    public …