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

如上所述，有Share，但此API不允许设置最小订阅者数量，因此最好调用下面的函数，就我而言，我想等到我们有两个订阅者。文档状态

第一次订阅时导致源Flux订阅一次的Flux，因此延迟订阅的用户可能会错过项目。

val flux = Flux.just("MyData1", "MyData2", "MyData3").publish().refCount(2)

这将生成以下输出，以确保在启动第二个订阅服务器时出现延迟时不会丢失消息。

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