我有无限流,消息表示为Play Enumerator,我将Iteratee应用于其中。然后由Akka参与者处理每条消息(参与者的数量限制在10人以内)。现在,我希望Iteratee中的代码异步地等待空闲的参与者,如果所有10个参与者都很忙,并且不向他们发送另一条导致异常Ask timed out on ...的消息。
如何实现这样的功能?是否有更好的方法来处理无await**?**的10个参与者<e
我正在尝试使用Python生成器来再现反应性扩展“共享”的可观察概念。假设我有一个API,它给了我一个无限流,我可以这样使用: for elem in the_infinite_stream():我可以多次使用这个生成器,如:stream2 = my_generator()
the_infinite_stream()将被调用两次(每个生成器一次现在假设