Hey guys, I have a question about manifold, not sure if this is the appropriate channel since I couldn't find a manifold-specific channel.

I'm building a pubsub system on top of manifold.bus and I don't understand why subcribers stop consuming a bus stream when an error is thrown. Any ideas?

manifold doesn't deal with errors very well - there are some places where an error thrown can silently close a stream @guswill

this caused us no end of trouble at some point... we wrap the stream api now to make sure it never happens and flow errors downstream sensibly

Thanks for the pointers @mccraigmccraig. Is this wrapping lib open source by any chance?

For now I'm wrapping consumers in a exception-handling macro, but it feels kinda hack-ish.

Would you say core.async is a better option for unreliable consumers in fan-out topologies then?

core.async doesn't have the best error handling story either 😞