Duplex stream collecting all input