Question: why does `stream/zip` need an intermediaries stream layer?

[dm3]

I was wondering, why does the implementation of manifold.stream/zip create an intermediary stream for each input stream instead of "zipping" the input streams directly?

[ztellman]

Because if loop/recur and connect based consumers are both given the same
stream, the loop/recur consumer may miss messages. Consider the case where
there are no intermediate streams, and we both map and zip over a
particular stream.
On Fri, Jul 22, 2016 at 3:19 PM Vadim Platonov notifications@github.com
wrote:

I was wondering, why does the implementation of manifold.stream/zip
create an intermediary stream for each input stream
https://github.com/ztellman/manifold/blob/master/src/manifold/stream.clj#L649
instead of "zipping" the input streams directly?

—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub
#87, or mute the thread
https://github.com/notifications/unsubscribe-auth/AAB6PzZpFEMDHNh-vA3j8bJP7wXLrlOEks5qYRetgaJpZM4JTDWN
.

[dm3]

Makes sense, thanks!