An implementation of an event bus, where publishers and subscribers can interact via topics.
Positional factory function for class manifold.bus.Wrapper.
(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