manifold.stream.default — org.clojars.pithyless/manifold 0.1.9-alpha4

add! clj

(add! producers consumers messages capacity executor)

de-nil clj

(de-nil x)

onto clj

(onto ex s)

re-nil clj

(re-nil x)

stream clj

(stream)

(stream buffer-size)

(stream buffer-size xform)

(stream buffer-size xform executor)

stream* clj

(stream* {:keys [permanent? buffer-size description executor xform]
          :or {permanent? false executor (ex/executor)}})