Liking cljdoc? Tell your friends :D
Clojure only.
async-messaging.in-mem-event-bus.core
iterate-consumer-map-add-listeners!clj
(iterate-consumer-map-add-listeners! threads-atom
stop?-atom
consumer-map
event-bus)poll-queue!clj
(poll-queue! event-bus queue-key handler stop?)Continuously pops messages from the given queue key in event-bus
and invokes handler on each. Stops when stop? atom becomes true.
Continuously pops messages from the given `queue` key in `event-bus` and invokes `handler` on each. Stops when `stop?` atom becomes true.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close