I have recently published a guide to Error handling in Clojure Core.Async (and its higher-level constructs):
Error handling is something that core.async leaves to you (because it depends on your particular use case). People have written before about handling errors in the low-level go loops but there is little about the higher level constructs such as pipelines and transducers. I’d like to correct that. First, a little repetition.
Read the rest…
Feedback appreciated!