glossop.util
intoclj/s
(into coll ch)async/into with short-circuiting on the first error
async/into with short-circuiting on the first error
keyed-mergeclj/s
(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?clj/s
(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.
reduceclj/s
(reduce f init ch)async/reduce with short-circuiting on the first error
async/reduce with short-circuiting on the first error
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close