【问题标题】:Subscribe to the same inbound more than once?多次订阅同一个入站?
【发布时间】:2020-12-27 15:32:55
【问题描述】:

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

【问题讨论】:

    标签: reactor-netty


    【解决方案1】:

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

    【讨论】:

    • 我尝试了 share() 并让它按我想要的方式工作。显然使用缓存也可以。谢谢。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-07-30
    • 2018-02-13
    • 2018-02-02
    • 2019-02-10
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多