clojure.core.async.impl.protocols
(source)For more info about this library see:
https://clojuredocs.org/clojure.core.async| Public Variable | Short Description |
|---|---|
| Buffer (clj) | |
| Channel (clj) | |
| Executor (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. |
| exec (clj) | execute runnable asynchronously. |
| full? (clj) | returns true if buffer cannot accept put. |
| lock-id (clj) | a unique id for lock acquisition order, 0 if no lock. |
| put! (clj) | derefable boolean (false iff 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. |