hitchhiker.tree.utils.async — io.replikativ/hitchhiker-tree 0.1.9

*async?* clj/s

<? clj/s macro

(<? ch)

Same as core.async <! but throws an exception if the channel returns a throwable error.

<?? clj macro

(<?? ch)

Same as core.async <!! but throws an exception if the channel returns a throwable error.

chan-seq clj

(chan-seq ch)

go-try clj/s macro

(go-try & body)

Asynchronously executes the body in a go block. Returns a channel which will receive the result of the body when completed or the exception if an exception is thrown. You are responsible to take this exception and deal with it! This means you need to take the result from the channel at some point.

if-async? clj/s macro

(if-async? then else)

promise-chan clj/s

(promise-chan x)

reduce< clj/s

(reduce< go-f init s)

Reduces over a sequence s with a go function go-f given the initial value init.

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.