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(),并可以订阅获取值。
| 归档时间: |
|
| 查看次数: |
382 次 |
| 最近记录: |