clojurewerkz.meltdown.consumers — clojurewerkz/meltdown 2.0.0-SNAPSHOT

Operations on consumers and registrations

cancel clj

(cancel reg)

cancel-after-use clj

(cancel-after-use reg)

cancel-after-use? clj

(cancel-after-use? reg)

cancelled? clj

(cancelled? reg)

consumer-count clj

(consumer-count r)

consumer-registry-of clj

(consumer-registry-of r)

consumers-on clj

(consumers-on r)

from-fn clj

(from-fn f)

Instantiates a transforming Reactor consumer from a Clojure function. The consumer will automatically convert Reactor events to Clojure maps.

from-fn-raw clj

(from-fn-raw f)

Instantiates a reactor consumer from a Clojure function

pause clj

(pause reg)

paused? clj

(paused? reg)

resume clj

(resume reg)