Liking cljdoc? Tell your friends :D

clojure.core.async.impl.protocols


add!clj

(add! b)
(add! b itm)
source

Buffercljprotocol

add!*clj

(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-buf!clj

(close-buf! b)

called on chan closed under chan mutex, return ignored

called on chan closed under chan mutex, return ignored

full?clj

(full? b)

returns true if buffer cannot accept put

returns true if buffer cannot accept put

remove!clj

(remove! b)

remove and return next item from buffer, called under chan mutex

remove and return next item from buffer, called under chan mutex
source

Channelcljprotocol

close!clj

(close! chan)

closed?clj

(closed? chan)
source

Executorcljprotocol

execclj

(exec e runnable)

execute runnable asynchronously

execute runnable asynchronously
source

Handlercljprotocol

active?clj

(active? h)

returns true if has callback. Must work w/o lock

returns true if has callback. Must work w/o lock

blockable?clj

(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

commitclj

(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

lock-idclj

(lock-id h)

a unique id for lock acquisition order, 0 if no lock

a unique id for lock acquisition order, 0 if no lock
source

MAX-QUEUE-SIZEclj

source

ReadPortcljprotocol

take!clj

(take! port fn1-handler)

derefable val if taken, nil if take was enqueued

derefable val if taken, nil if take was enqueued
source

UnblockingBuffercljprotocol

source

WritePortcljprotocol

put!clj

(put! port val fn1-handler)

derefable boolean (false iff already closed) if handled, nil if put was enqueued. Must throw on nil val.

derefable boolean (false iff already closed) if handled, nil if put was enqueued. Must throw on nil val.
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close