clj-tape.blocking — org.clojars.ejschoen/clj-tape 0.4.1

ConcurrentQueue clj protocol

Protocol for concurrently-accessed queues, supporting atomic take!

is-closed? clj

(is-closed? _)

Return true if queue is closed.

take! clj

(take! _)

(take! _ timeout timeout-val)

Atomically peek-and-remove

make-blocking-queue clj

(make-blocking-queue queue & {:keys [timeout] :as options})