jtk-dvlp.async — jtk-dvlp/core.async-helpers 3.3.2

<! clj/s macro

(<! ?exp)

Like core.async/<! but tests taken val of exception (ExceptionInfo), if so throws it.

<? clj/s macro

(<? sync-or-async-exp)

Like <! but can handle channels and non channel values.

all clj/s

(all chs)

Alias for (map vector chs) providing an vector of all resolved values.

amap clj/s

(amap <f & xs)

Like clojure.core/map but given function <f is async. Execution of <f with values of xs can be unordered an for clojure (not clojurescript) in parallel. Carries thrown exception (will convert to ExceptionInfo) as result.

Also see smap

apostwalk clj/s

(apostwalk <f form)

Like clojure.core/postwalk but given function <f is async. Execution with values of form can be unordered an for clojure (not clojurescript) in parallel. Carries thrown exception (will convert to ExceptionInfo) as result.

aprewalk clj/s

(aprewalk <f form)

Like clojure.core/prewalk but given function <f is async. Execution with values of form can be unordered an for clojure (not clojurescript) in parallel. Carries thrown exception (will convert to ExceptionInfo) as result.

areduce clj/s

(areduce <f init coll)

Like clojure.core/reduce but given function <f is async. Carries thrown exception (will convert to ExceptionInfo) as result.

awalk clj/s

(awalk <inner <outer form)

Like clojure.core/walk but given function <inner and <outer are async. Execution with values of form can be unordered an for clojure (not clojurescript) in parallel. Carries thrown exception (will convert to ExceptionInfo) as result.

chain clj/s

Alias for smap

chan? clj/s

(chan? x)

consume! clj/s

(consume! ch f)

Consumes channel ch executing function f for every value on channel. Spawns a new thread for execution on the JVM. Execution will be asynchron. Call returns immediately with nil. Thrown exceptions will abort consume.

exception? clj/s

(exception? x)

go clj/s macro

(go & body)

Like core.async/go but carries thrown exception (will convert to ExceptionInfo) as result.

go-loop clj/s macro

(go-loop bindings & body)

Like core.async/go-loop but carries thrown exception (will convert to ExceptionInfo) as result.

into clj/s

(into coll ch)

Like core.async/into but carries thrown exception (will convert to ExceptionInfo) as result.

map clj/s

(map f chs)

Like core.async/map but carries thrown exception (will convert to ExceptionInfo) as result.

reduce clj/s

(reduce f init ch)

Like core.async/reduce but carries thrown exception (will convert to ExceptionInfo) as result.

smap clj/s

(smap <f & xs)

Like clojure.core/map but given function <f is async. Execution of <f with values of xs will be sequential with the given order of xs. Carries thrown exception (will convert to ExceptionInfo) as result.

Also see amap