manifold.stream.default — manifold 0.2.2

add! clj

(add! producers consumers messages capacity executor dirty-puts)

Consumer clj

de-nil clj

(de-nil x)

max-consumers clj

Maximum number of pending consumers

max-dirty-puts clj

Every X puts, scan for timed-out deferreds and remove

max-dirty-takes clj

Every X takes, scan for timed-out deferreds and remove

max-producers clj

Maximum number of pending producers

onto clj

(onto ex s)

Producer clj

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)}})