1. module duplexer2
   1. function duplexer2 (options, writable, readable)
   2. function duplexer2.DuplexWrapper (options, writable, readable)
   3. object duplexer2.DuplexWrapper.prototype
2. module duplexer2.DuplexWrapper
   1. function duplexer2.DuplexWrapper (options, writable, readable)
3. module duplexer2.DuplexWrapper.prototype
   1. function duplexer2.DuplexWrapper.prototype._read ()
   2. function duplexer2.DuplexWrapper.prototype._write (input, encoding, done)

module duplexer2

function duplexer2 (options, writable, readable)

• description and source-code

  function duplex2(options, writable, readable) {
    return new DuplexWrapper(options, writable, readable);
  }

• example usage

  n/a

function duplexer2.DuplexWrapper (options, writable, readable)

• description and source-code

  function DuplexWrapper(options, writable, readable) {
    if (typeof readable === "undefined") {
      readable = writable;
      writable = options;
      options = null;
    }
  
    stream.Duplex.call(this, options);
  
    if (typeof readable.read !== "function") {
      readable = (new stream.Readable(options)).wrap(readable);
    }
  
    this._writable = writable;
    this._readable = readable;
    this._waiting = false;
  
    var self = this;
  
    writable.once("finish", function() {
      self.end();
    });
  
    this.once("finish", function() {
      writable.end();
    });
  
    readable.on("readable", function() {
      if (self._waiting) {
        self._waiting = false;
        self._read();
      }
    });
  
    readable.once("end", function() {
      self.push(null);
    });
  
    if (!options || typeof options.bubbleErrors === "undefined" || options.bubbleErrors) {
      writable.on("error", function(err) {
        self.emit("error", err);
      });
  
      readable.on("error", function(err) {
        self.emit("error", err);
      });
    }
  }

• example usage

  n/a

module duplexer2.DuplexWrapper

function duplexer2.DuplexWrapper (options, writable, readable)

• description and source-code

  function DuplexWrapper(options, writable, readable) {
    if (typeof readable === "undefined") {
      readable = writable;
      writable = options;
      options = null;
    }
  
    stream.Duplex.call(this, options);
  
    if (typeof readable.read !== "function") {
      readable = (new stream.Readable(options)).wrap(readable);
    }
  
    this._writable = writable;
    this._readable = readable;
    this._waiting = false;
  
    var self = this;
  
    writable.once("finish", function() {
      self.end();
    });
  
    this.once("finish", function() {
      writable.end();
    });
  
    readable.on("readable", function() {
      if (self._waiting) {
        self._waiting = false;
        self._read();
      }
    });
  
    readable.once("end", function() {
      self.push(null);
    });
  
    if (!options || typeof options.bubbleErrors === "undefined" || options.bubbleErrors) {
      writable.on("error", function(err) {
        self.emit("error", err);
      });
  
      readable.on("error", function(err) {
        self.emit("error", err);
      });
    }
  }

• example usage

  n/a

module duplexer2.DuplexWrapper.prototype

function duplexer2.DuplexWrapper.prototype._read ()

• description and source-code

  function _read() {
    var buf;
    var reads = 0;
    while ((buf = this._readable.read()) !== null) {
      this.push(buf);
      reads++;
    }
    if (reads === 0) {
      this._waiting = true;
    }
  }

• example usage

  ...
  this.once("finish", function() {
    writable.end();
  });
  
  readable.on("readable", function() {
    if (self._waiting) {
      self._waiting = false;
      self._read();
    }
  });
  
  readable.once("end", function() {
    self.push(null);
  });
  ...

function duplexer2.DuplexWrapper.prototype._write (input, encoding, done)

• description and source-code

  function _write(input, encoding, done) {
    this._writable.write(input, encoding, done);
  }

• example usage

  n/a