core.async
utilities, for parallel generation.
`core.async` utilities, for parallel generation.
(chan? x)
Is x
a proper core.async
channel?
Is `x` a proper `core.async` channel?
(heads-chans chans)
(heads-chans compfn chans)
Get a sorted map of [head-val <channel>]
, where channel
is open.
Get a sorted map of `[head-val <channel>]`, where `channel` is open.
(sequence-messages chans)
(sequence-messages out-chan compfn chans)
Given an output channel out-chan
, comparator compfn
, and one or more
channels chans
containing ordered values, returns a channel that will
receive an ordered sequence of messages, closing when the last channel
closes.
Given an output channel `out-chan`, comparator `compfn`, and one or more channels `chans` containing ordered values, returns a channel that will receive an ordered sequence of messages, closing when the last channel closes.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close