1

从DirectProcessor，spring-reactor 3.x文档：

向零对多订阅者发送 onNext、onError 和 onComplete 信号。请注意，与多个消费者一起，DirectProcessor 的当前实现支持多个生产者。但是，所有生产者必须在同一个线程上产生消息，否则将违反 Reactive Streams Spec 合同。

上述声明中的生产者是什么？

  1. aPublisher接收DirectProcessor作为Publisher.subscribe方法的参数
  2. 呼唤的东西DirectProcessor.onNext(T t)
  3. 调用FluxSink<T>.next(T t)FluxSink的结果DirectProcessor.sink()
4

0 回答 0