@lxsameer there are protocols for that, called Sourceable and Sinkable. And also various macros to help with that
Still, a guide of how to implement it would be helpful
cool, I'll write it if I end up doing it
Anyway, i have a concern about stream, and is the exception handling
With deferred, you can add (d/catch)
there isn't any exception handling on streams @jimenezsaezjoseantoni - see https://github.com/ztellman/manifold/issues/95
in places where i really need it i implement it ad-hoc by e.g. catching exceptions in mapped fns and turning them in to values on the stream i can pattern match on
yep, i was thinking in that
in transforming the message down the stream
into {:message :error {} }