Nice! I’ve been looking for this for a while. But how about error handling? It is trivial when the code is synchronous and buffering. Do you have to introduce a channel for this or is there another way?