Fork me on GitHub
#aleph
<
2018-03-12
>
logistark13:03:08

@lxsameer there are protocols for that, called Sourceable and Sinkable. And also various macros to help with that

logistark13:03:42

Still, a guide of how to implement it would be helpful

lxsameer13:03:16

cool, I'll write it if I end up doing it

logistark15:03:51

Anyway, i have a concern about stream, and is the exception handling

logistark15:03:06

With deferred, you can add (d/catch)

mccraigmccraig16:03:22

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

logistark16:03:12

yep, i was thinking in that

logistark16:03:30

in transforming the message down the stream

logistark16:03:42

into {:message :error {} }