Consume a duplexStream instead of a DuplexEmitter
2.0.0