Project Reactor将发布者一分为二

Question

如何在Reactor中将发布者一分为二，因此存在两个相同的数据流，可以在下游以不同的流进行处理？

因此，我可以映射每个流并分别订阅每个流。

我在API中看不到任何表明它在API上的内容。

Answer 1

感谢您的输入并没有直截了当，当然只有多个订阅者：

  val flux = Flux.just("MyData1", "MyData2", "MyData3");

  flux.doOnNext { println("Subscribing one$it") }.subscribe()

  flux.doOnNext { println("Subscribing Two$it") }.subscribe()

将输出：

Subscribing oneMyData1
Subscribing oneMyData2
Subscribing oneMyData3
Subscribing TwoMyData1
Subscribing TwoMyData2
Subscribing TwoMyData3