(add! b)
(add! b itm)
(remove! b)
remove and return next item from buffer, called under chan mutex
remove and return next item from buffer, called under chan mutex
(close-buf! b)
called on chan closed under chan mutex, return ignored
called on chan closed under chan mutex, return ignored
(full? b)
returns true if buffer cannot accept put
returns true if buffer cannot accept put
(add!* b itm)
if room, add item to the buffer, returns b, called under chan mutex
if room, add item to the buffer, returns b, called under chan mutex
(close! chan)
(closed? chan)
(blockable? h)
returns true if this handler may be blocked, otherwise it must not block
returns true if this handler may be blocked, otherwise it must not block
(active? h)
returns true if has callback. Must work w/o lock
returns true if has callback. Must work w/o lock
(commit h)
commit to fulfilling its end of the transfer, returns cb. Must be called within lock
commit to fulfilling its end of the transfer, returns cb. Must be called within lock
(take! port fn1-handler)
derefable val if taken, nil if take was enqueued
derefable val if taken, nil if take was enqueued
(put! port val fn1-handler)
derefable boolean (false if already closed) if handled, nil if put was enqueued. Must throw on nil val.
derefable boolean (false if already closed) if handled, nil if put was enqueued. Must throw on nil val.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close