(into coll ch)async/into with short-circuiting on the first error
async/into with short-circuiting on the first error
(keyed-merge ch->tag)(keyed-merge ch->tag buf-or-n)Merge a map of channel->opaque into a single channel containing a sequence of pairs ([opaque value] ...). Each pair associates an input value to the result of reading from the corresponding channel. As with merge, the returned channel will be unbuffered by default, or a buf-or-n can be supplied. The channel will close after all the source channels have closed.
Merge a map of channel->opaque into a single channel containing a sequence of pairs ([opaque value] ...). Each pair associates an input value to the result of reading from the corresponding channel. As with merge, the returned channel will be unbuffered by default, or a buf-or-n can be supplied. The channel will close after all the source channels have closed.
(onto-chan? ch coll)A variation of async/onto-chan indicates whether all puts were accepted. Never closes the destination channel. The returned channel will resolve to a false value if the destination channel closes, or true if all puts are completed.
A variation of async/onto-chan indicates whether all puts were accepted. Never closes the destination channel. The returned channel will resolve to a false value if the destination channel closes, or true if all puts are completed.
(reduce f init ch)async/reduce with short-circuiting on the first error
async/reduce with short-circuiting on the first error
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |