| Public Variable |
Short Description |
|
Buffer (clj)
|
|
|
Channel (clj)
|
|
|
Handler (clj)
|
|
|
MAX-QUEUE-SIZE (clj)
|
|
|
ReadPort (clj)
|
|
|
UnblockingBuffer (clj)
|
|
|
WritePort (clj)
|
|
|
active? (clj)
|
returns true if has callback. |
|
add! (clj)
|
|
|
add!* (clj)
|
if room, add item to the buffer, returns b, called under chan mutex. |
|
blockable? (clj)
|
returns true if this handler may be blocked, otherwise it must not block. |
|
close! (clj)
|
|
|
close-buf! (clj)
|
called on chan closed under chan mutex, return ignored. |
|
closed? (clj)
|
|
|
commit (clj)
|
commit to fulfilling its end of the transfer, returns cb. |
|
full? (clj)
|
returns true if buffer cannot accept put. |
|
put! (clj)
|
derefable boolean (false if already closed) if handled, nil if put was enqueued. |
|
remove! (clj)
|
remove and return next item from buffer, called under chan mutex. |
|
take! (clj)
|
derefable val if taken, nil if take was enqueued. |