【发布时间】:2020-12-27 15:32:55
【问题描述】:
在 reactor netty 中,是否可以多次订阅同一个入站?我注意到 startReceiver 方法变量 once 设置为 1,并且没有其他代码路径会将其设置回 0,因此任何尝试订阅入站的新订阅者都不会有机会调用 onSubscribe。不同的订阅者可以订阅同一个入站吗? (我知道这是一个非常菜鸟甚至是无效的问题,如果它甚至不值得问,请告诉我。)
【问题讨论】:
标签: reactor-netty
在 reactor netty 中,是否可以多次订阅同一个入站?我注意到 startReceiver 方法变量 once 设置为 1,并且没有其他代码路径会将其设置回 0,因此任何尝试订阅入站的新订阅者都不会有机会调用 onSubscribe。不同的订阅者可以订阅同一个入站吗? (我知道这是一个非常菜鸟甚至是无效的问题,如果它甚至不值得问,请告诉我。)
【问题讨论】:
标签: reactor-netty
不能多次订阅传入数据。 Reactor Netty 不缓存它。 您可以使用 cache Reactor 操作符或其他一些机制来缓存传入的数据,然后在需要时对其进行多次操作。
【讨论】: