#core.async

I.e. a single core.async pipeline shared by many writers-readers (from different threads). Handles exceptions and misbehaving readers that stop reading and could thus block the pipeline.

This library tries to enrich the language of core.async by providing the useful idioms which often repeat across code bases in some variation, among which are: producing/consuming to channels at the edges of a system, dispatching/routing channels, batching, waiting for a group of tasks.

Error-propagating (ie. re-throwing) versions of go[-loop], map, etc and callback and promise integration.

A custom varsion of go-loop supporting stopping the loops. Ideal for testing, REPL I guess?

While go-try and the ? expressions work well when you have a sequential execution of goroutines,they do not fit concurrent goroutines like go-loops or background tasks.For those, the library introduces an Erlang inspired supervision concept.

Error propagation through checking if value read is an error and rethrowing + go-try

Useful macros/functions for common boilerplate such as producing into / consuming from a channel, with error handling.

Catch and rethrow support in go blocks and Erlang-style supervision.