Liking cljdoc? Tell your friends :D

intake.core.async

Namespace for adapting manifold streams as core.async channels.

This namespace doesn't provide much of anything interesting aside from extending protocols; just require this namespace to make manifold streams usable with core.async operations.

Namespace for adapting manifold streams as core.async
channels.

This namespace doesn't provide much of anything interesting
aside from extending protocols; just require this namespace
to make manifold streams usable with core.async operations.
raw docstring

drained?clj

(drained? this)
source

take-from-queue!clj

(take-from-queue! this stream handler)
source

with-lockcljmacro

(with-lock lock & body)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close