Liking cljdoc? Tell your friends :D

cljs.core.async.impl.protocols


add!cljs

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

Buffercljsprotocol

remove!cljs

(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!cljs

(close-buf! b)

called on chan closed under chan mutex, return ignored

called on chan closed under chan mutex, return ignored

full?cljs

(full? b)

returns true if buffer can accept put

returns true if buffer can accept put

add!*cljs

(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
source

Channelcljsprotocol

close!cljs

(close! chan)

closed?cljs

(closed? chan)
source

Handlercljsprotocol

blockable?cljs

(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?cljs

(active? h)

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

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

commitcljs

(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
source

MAX-QUEUE-SIZEcljs

source

ReadPortcljsprotocol

take!cljs

(take! port fn1-handler)

derefable val if taken, nil if take was enqueued

derefable val if taken, nil if take was enqueued
source

UnblockingBuffercljsprotocol

source

WritePortcljsprotocol

put!cljs

(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.
source

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

× close