6

处理器（RxJava 中的主题）既充当发布者又充当订阅者，因此它们可以订阅发布者，此外，还可以被订阅，以便传递从顶级订阅者获得的值：

Publisher
   |
   \/
 Processor
   |
   \/
Subscriber

如何FluxProcessor.wrap()适应这个模式？例如，我想创建一个从 a 获取值并且可以订阅以获取值的FluxProcessorwith 。FluxProcessor.wrapFlux.range()

4

0 回答 0