fluree.db.util.async — com.fluree/db 1.0.0-rc3

<? clj/s macro

(<? ch)

Like <! but throws errors.

<?? clj/s macro

(<?? ch)

Like <!! but throws errors. Only works for Java platform - no JavaScript.

channel? clj/s

(channel? x)

Returns true if core async channel.

cljs-env? clj

(cljs-env? env)

Take the &env from a macro, and tell whether we are expanding into cljs.

go-try clj/s macro

(go-try & body)

Like go but catches the first thrown error and returns it.

if-cljs clj/s macro

(if-cljs then else)

Return then if we are generating cljs code and else for Clojure code. https://groups.google.com/d/msg/clojurescript/iBY5HaQda4A/w1lAQi9_AwsJ

into? clj/s

(into? coll chan)

Like async/into, but checks each item for an error response and returns exception onto the response channel insted of results if thee is one.

merge-into? clj/s

(merge-into? coll chs)

Takes a sequence of single-value chans and returns the conjoined into collection. Realizes entire channel sequence first, and if an error value exists returns just the exception.

throw-err clj/s

(throw-err e)

throw-if-exception clj/s

(throw-if-exception x)

Helper method that checks if x is Exception and if yes, wraps it in a new exception, passing though ex-data if any, and throws it. The wrapping is done to maintain a full stack trace when jumping between multiple contexts.