An implementation of an event bus, where publishers and subscribers can interact via topics.
(active? bus topic)
true if there are any subscribers to
(downstream bus topic)
Returns a list of all streams subscribed to
Returns an event bus that can be used with
(publish! bus topic message)
Publishes a message on the bus, returning a deferred result representing the message being accepted by all subscribers. To prevent one slow consumer from blocking all the others, use
manifold.stream/connect with a timeout specified.
(subscribe bus topic)
Returns a stream which consumes all messages from