多次订阅同一个入站？

Question

在reactor netty中，是否可以多次订阅同一个入站？我注意到在 startReceiver 方法中变量 once 被设置为 1 并且没有其他代码路径将它设置回 0，因此任何试图订阅入站的新订阅者将永远没有机会调用 onSubscribe。不同的订阅者是否可以订阅相同的入站？ （我知道这是一个非常菜鸟甚至无效的问题，如果它甚至不值得问请告诉我。）

Answer 1

不能多次订阅传入数据。 Reactor Netty 不缓存它。 您可以使用缓存 Reactor 运算符或其他一些机制来缓存传入数据，然后在需要时对其进行多次操作。