serum.async

Liking cljdoc? Tell your friends :D

Clojure only.

<?
<??
chan->seq
fire!
map-async
throw-exceptions

<?^cljmacro

(<? channel)

source

<??^cljmacro

(<?? channel)

source

chan->seq^clj

(chan->seq channel)

recursive function which derives a lazy sequence from a core.async channel, channel. Intended for use on main thread.

recursive function which derives a lazy sequence from a core.async channel, `channel`.
Intended for use on main thread.

source raw docstring

fire!^cljmacro

(fire! body)

execute 'body' on an asynchronous worker thread via a core.async channel. (fire! and forget)

execute 'body' on an asynchronous worker thread via a core.async channel.
(fire! and forget)

source raw docstring

map-async^clj

(map-async f coll)

(map-async f n coll)

an asynchronous implementation of map returns a lazy sequence of the asynchronous evaluation of f applied to members of the collection coll will block until all asynchronous evaluation completes. Intended for use on main thread. f single-argument function n parallelization parameter coll collection applied to the function f

an asynchronous implementation of `map`
returns a lazy sequence of the asynchronous evaluation of `f` applied to members of the collection `coll`
will block until all asynchronous evaluation completes.
Intended for use on main thread.
`f` single-argument function
`n` parallelization parameter
`coll` collection applied to the function `f`

source raw docstring