clojurewerkz.meltdown.reactor.streams — clojurewerkz/meltdown 2.0.0-SNAPSHOT

anonymous-stream clj macro

(anonymous-stream reactor root-key downstream-key & forms)

batch* clj

(batch* reactor selector downstream-key i)

consume clj

(consume reactor selector f)

(consume reactor selector downstream-key f)

filter* clj

(filter* reactor selector downstream-key filter-fn)

map* clj

(map* reactor selector downstream-key f)

reduce* clj

(reduce* reactor selector downstream-key f initial)

split* clj

(split* reactor selector downstream-key split-fn)