admix function clojure.core.async Adds ch as an input to the mix. alt! macro clojure.core.async Makes a single choice between one of several chann... alt!! macro clojure.core.async Like alt!, except as if by alts!!, will block unti... alts! function clojure.core.async Completes at most one of several channel operation... alts!! function clojure.core.async Like alts!, except takes will be made as if by <!!...
buffer function clojure.core.async Returns a fixed buffer of size n. When full, puts ...
chan function clojure.core.async Creates a channel with an optional buffer, an opti... close! function clojure.core.async Closes a channel. The channel will no longer accep... command-proc function clojure.core.async.flow.impl.graph synchronously sends a process-spec...
describe function clojure.core.async.flow.spi returns a map with keys - :params, :ins a... do-alts function clojure.core.async returns derefable [val port] if immediate, nil if ... dropping-buffer function clojure.core.async Returns a buffer of size n. When full, puts will c...
get-exec function clojure.core.async.flow.spi returns the ExecutorService for the given... get-write-chan function clojure.core.async.flow.spi Given a tuple of [pid cid], returns a cor... go macro clojure.core.async Asynchronously executes the body, returning immedi... go-loop macro clojure.core.async Like (go (loop ...)). Graph protocol clojure.core.async.flow.impl.graph
inject function clojure.core.async.flow.impl.graph synchronously puts the messages on... into function clojure.core.async Returns a channel containing the single (collectio...
map function clojure.core.async Takes a function and a collection of source channe... merge function clojure.core.async Takes a collection of source channels and returns ... mix function clojure.core.async Creates and returns a mix of one or more input cha... mult function clojure.core.async Creates and returns a mult(iple) of the supplied c...
offer! function clojure.core.async Puts a val into port if it's possible to do so imm... onto-chan function clojure.core.async Deprecated - use onto-chan! or onto-chan!!. onto-chan! function clojure.core.async Puts the contents of coll into the supplied channe... onto-chan!! function clojure.core.async Like onto-chan! for use when accessing coll might ...
pause function clojure.core.async.flow.impl.graph pauses a running graph. pause-proc function clojure.core.async.flow.impl.graph pauses a process. ping function clojure.core.async.flow.impl.graph pings all processes, which will pu... ping-proc function clojure.core.async.flow.impl.graph pings the process, which will put ... pipe function clojure.core.async Takes elements from the from channel and supplies ... pipeline function clojure.core.async Takes elements from the from channel and supplies ... pipeline-async function clojure.core.async Takes elements from the from channel and supplies ... pipeline-blocking function clojure.core.async Like pipeline, for blocking operations.. poll! function clojure.core.async Takes a val from port if it's possible to do so im... ProcLauncher protocol clojure.core.async.flow.spi Note - definine a ProcLauncher is an adva... promise-chan function clojure.core.async Creates a promise channel with an optional transdu... pub function clojure.core.async Creates and returns a pub(lication) of the supplie... put! function clojure.core.async Asynchronously puts a val into port, calling fn1 (...
reduce function clojure.core.async f should be a function of 2 arguments. Returns a c... Resolver protocol clojure.core.async.flow.spi resume function clojure.core.async.flow.impl.graph resumes a paused graph. resume-proc function clojure.core.async.flow.impl.graph resumes a process.
sliding-buffer function clojure.core.async Returns a buffer of size n. When full, puts will c... solo-mode function clojure.core.async Sets the solo mode of the mix. mode must be one of... split function clojure.core.async Takes a predicate and a source channel and returns... start function clojure.core.async.flow.impl.graph starts the entire graph from init ... start function clojure.core.async.flow.spi return ignored, called for the effect of ... stop function clojure.core.async.flow.impl.graph shuts down the graph, stopping all... sub function clojure.core.async Subscribes a channel to a topic of a pub. By defa...
take function clojure.core.async Returns a channel that will return, at most, n ite... take! function clojure.core.async Asynchronously takes a val from port, passing to f... tap function clojure.core.async Copies the mult source onto the supplied channel. ... thread macro clojure.core.async Executes the body in another thread, returning imm... thread-call function clojure.core.async Executes f in another thread, returning immediatel... timeout function clojure.core.async Returns a channel that will close after msecs. to-chan function clojure.core.async Deprecated - use to-chan! or to-chan!!. to-chan! function clojure.core.async Creates and returns a channel which contains the c... to-chan!! function clojure.core.async Like to-chan! for use when accessing coll might bl... toggle function clojure.core.async Atomically sets the state(s) of one or more channe... transduce function clojure.core.async async/reduces a channel with a transformation (xfo...
unblocking-buffer? function clojure.core.async Returns true if a channel created with buff will n... unmix function clojure.core.async Removes ch as an input to the mix. unmix-all function clojure.core.async removes all inputs from the mix. unsub function clojure.core.async Unsubscribes a channel from a topic of a pub. unsub-all function clojure.core.async Unsubscribes all channels from a pub, or a topic o... untap function clojure.core.async Disconnects a target channel from a mult. untap-all function clojure.core.async Disconnects all target channels from a mult.
<! function clojure.core.async takes a val from port. Must be called inside a (go... <!! function clojure.core.async takes a val from port. Will return nil if closed. ... >! function clojure.core.async puts a val into port. nil values are not allowed. ... >!! function clojure.core.async puts a val into port. nil values are not allowed. ...