@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 {} }