I’ve got the following duplex stream. Input is a CSV string. When the limit of CSV lines is reached, a new CSV is created and added to a ZIP archive. So the pipeline flow is this:

I have an input stream that needs to be processed by two different pipelines. Therefore I have to duplicate the stream.

I have a Duplex stream object coming from a library that I’m piping into HTTP requests so the request and the response goes through it.