akka的broadcasthub,是否支持有指定个消费者的时候再开始消费他的上游,如果不支持,我想要提交一个pull request让它支持,你觉的broadcasthub这个类的构造函数应该如何改
进一步了解了您的问题后,我发现您想要实现的功能是在有指定个消费者时再开始消费上游,而不是在所有消费者都连接时开始消费。目前,BroadcastHub不支持此功能。
如果您想提交一个pull request来实现此功能,您需要修改BroadcastHub的源代码并添加新的构造函数或其他方法来支持此功能。您可以在BroadcastHub中添加一个参数,以指定有多少个消费者时才开始消费上游。这个参数可以是可选的,这样用户可以选择在所有消费者都连接时开始消费,或者在达到指定数量的消费者时开始消费。
您可以在Akka GitHub存储库中找到BroadcastHub的源代码并开始修改。在提交pull request之前,请确保您的修改经过了充分的测试,并且遵循Akka社区的代码规范和最佳实践。
希望这可以帮助您实现您的功能,并为Akka社区做出贡献!
原文地址: https://www.cveoy.top/t/topic/vXf 著作权归作者所有。请勿转载和采集!