cljs.core.async.impl.protocols
(source)For more info about this library see:
https://clojuredocs.org/clojure.core.asyncPublic 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. |