serum.async — waffletower/serum 0.11.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.

disorder-exec clj

(disorder-exec f coll)

(disorder-exec f opts coll)

asynchronously executes f upon members of coll. does not serially block on task (java.util.concurrent.FutureTask) de-referencing. only de-references tasks which are complete. order of output collection does not correspond to order of input. Imperative, not lazy. f single-argument function opts clojure hashmap containing the following key/value pairs: :pool-count thread pool thread count parameter :poll-millis main thread polling wait in milliseconds between completion checks (.isDone) nil skips wait (with stack overflow risk) - 10 ms default coll collection applied to the function f

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

side-exec clj

(side-exec f coll)

(side-exec f opts coll)

asynchronously executes f upon members of coll without retention of results. does not serially block on task (java.util.concurrent.FutureTask) de-referencing. only de-references tasks which are complete. Imperative, not lazy. f single-argument function opts clojure hashmap containing the following key/value pairs: :pool-count thread pool thread count parameter :poll-millis main thread polling wait in milliseconds between completion checks (.isDone) nil skips wait (with stack overflow risk) - 10 ms default coll collection applied to the function f

throw-exceptions clj

(throw-exceptions x)