serum.async — waffletower/serum 0.10.0

<? clj macro

(<? channel)

<?? clj macro

(<?? channel)

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.

fire! clj macro

(fire! body)

execute 'body' on an asynchronous worker thread. (fire! and forget)

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

map-exec clj

(map-exec f coll)

(map-exec f n coll)

an asynchronous implementation of map returns a vector 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. More efficient utilization of thread pool than map-async. Not fully lazy, however. f single-argument function n parallelization parameter coll collection applied to the function f

throw-exceptions clj

(throw-exceptions x)