docs: function srcStream(stream) {
    var pass = through.obj();
    pass.setMaxListeners(0);
  
    var outputstream = duplexify.obj(pass, ms(stream, pass));
    outputstream.setMaxListeners(0);
  
    var isReading = false;
    outputstream.on('pipe', function (src) {
      isReading = true;
      src.on('end', function () {
        isReading = false;
        outputstream.end();
      });
    });
  
    stream.on('end', function () {
      if (!isReading) {
        outputstream.end();
      }
    });
  
    return outputstream;
  }