Tag: rxjs frp

rx.js如何链接observables

我有一个可观察的事件，即将事件从服务器上拉下来，过滤应用程序types的事件，然后订阅和分派事件给一个或多个处理程序来处理。 处理程序然后离开，并做一些asynchronous更新到数据库，我发现可观察到将事件发展如此之快，更新互相踩。 我应该预料到的 所以我想我需要我的处理者，每个人都使用它自己的observable作为一个队列来处理一个事件并等待一个确认。 所以我的问题是，如何创build一个可持续接收消息的observable，并在发送下一条消息之前一次发送一条消息，等待确认。 另外，观察者需要冷。 我想，因为我不能放松信息。 谢谢， RAIF