Victor Vu

@ariutta Can you give a better example of what you're trying to do, as what you seem to be asking doesn't have anything to do with functional vs. not functional?...

I'm not a fan of allowing multiple thunks for a single stream for the exact reasons mentioned in this issue; I've never had to do it myself. So I would...

I don't understand your latter case...how can you continue to push values after the end of the stream?

@ibash Ok, i get what you're saying. There will need be a way to differentiate between getting a `nil` from upstream (so you can start your sort), and getting a...

I'm not sure on the exact API yet, I like handlers better than special values too. Using a special value may be complicated in implementation. I was thinking more along...

Writing `nil` won't work if the streams have buffered data. Not to mention that it won't even be emitted until downstream requests another element (which it won't because it's ended)....

The chaining syntax - lets you bind handlers without having done the `consume` (I was expecting to allow an array of handlers), - lets you bind handlers to streams constructed...

Or just don't bother passing a reason at all until someone comes up with a good use case for doing so... The minimalist in me probably prefers this more.

Oh, sorry! My browser must have been misbehaving.

Yeah, late forks have always had this issue. What's going on here is that the late fork doesn't exert back-pressure immediately since it comes in late; the decision to generate...