Zipping streams

Writing the following is easy after glancing through the documentation for conduit:

Neither pipes nor streaming make it as easy to figure out. I must be missing something! What functions should I be looking at?

⟸ Picking up new rows in a DB

Magnus Therning

@Jack Kelly: I might be wrong, but as far as I understand your code using Streaming.Prelude.copy is not equivalent because you end up with two sinks. It’s the re-combining of the streams that I’m after because that lets me organise my code and set up the whole stream processing in a very nice way, e.g. for testing I just switch out the source, src, and the sink, sink, for pure variants.

Leave a comment