do you mean in this case? https://clojurians.slack.com/archives/C0G922PCH/p1545583944000800 when something happens in user’s code that executes on s/take!?

yeah it’s related

@U052BJL37 any idea my friend ?

I assume we’re talking about non-blocking case, when s/take! returns deferred, right?

yes

I’m not sure I do understand the question correctly… when I have an exception raised somewhere in the chain of callbacks attached to the deferred returned by take!… nothing closes the stream