了解反应堆的FluxProcessor.wrap(上游,下游)

cod*_*ent 5 spring reactor reactive-programming rx-java project-reactor

处理器(RxJava中的主题)既充当发布者又充当订阅者,因此它们可以订阅发布者,此外还可以进行订阅,以便它们传递从顶级订阅者获得的值:

Publisher
   |
   \/
 Processor
   |
   \/
Subscriber
Run Code Online (Sandbox Code Playgroud)

如何FluxProcessor.wrap()适应这种模式?比如我想创建一个FluxProcessor具有FluxProcessor.wrap从该得到的值Flux.range(),并可以订阅获取值。