cutty-sark.async-utils — otann/cutty-sark 0.1.0

<!!* clj

(<!!* channels timeout)

Synchronizes over a sequence of channels and returns a vector of result from each channel. If one of the channels times out, result will be nil.

<!!? clj macro

(<!!? c)

Version of <!! that throw Exceptions that come out of any of the channels.

<!* clj

(<!* channels)

Synchronizes over a sequence of channels and returns a vector of result from each channel.

<? clj macro

(<? c)

Version of <! that throw Exceptions that come out of a channel.

<some! clj

(<some! channels timeout)

Gets ready values from list of channels before timeout is reached. Even if some channel times out, others will make it to the result.

<some!! clj

(<some!! channels timeout)

Gets ready values from list of channels before timeout is reached. Even if some channel times out, others will make it to the result.

go-let clj macro

(go-let bindings & body)

Shorthand for (go (let [])

go-try clj macro

(go-try & body)

Version of go that will catch all exceptions and return them as a channel result

thread-try clj macro

(thread-try & body)

Catches exceptions happening inside body and puts them in a channel as a result

with-timeout clj

(with-timeout channel timeout)

Wraps channel so it will return either a value or a ::timeout after certain time passes