FM / duplexer2

/var/www/greso.tech/server/nsm/node_modules/duplexer2/

/var/www/greso.tech/server/nsm/node_modules/duplexer2

Name	Size	Mode	Actions
node_modules/	-	0755	rm
test/	-	0755	rm
.npmignore	14	0644	edit dl rm
.travis.yml	38	0644	edit dl rm
example.js	988	0755	edit dl rm
index.js	1482	0644	edit dl rm
LICENSE.md	1535	0644	edit dl rm
package.json	661	0644	edit dl rm
README.md	2665	0644	edit dl rm

Edit: /var/www/greso.tech/server/nsm/node_modules/duplexer2/index.js (1482B)

var stream = require("readable-stream");

var duplex2 = module.exports = function duplex2(options, writable, readable) {
  return new DuplexWrapper(options, writable, readable);
};

var DuplexWrapper = exports.DuplexWrapper = function DuplexWrapper(options, writable, readable) {
  if (typeof readable === "undefined") {
    readable = writable;
    writable = options;
    options = null;
  }

options = options || {};
  options.objectMode = true;

stream.Duplex.call(this, options);

this._bubbleErrors = (typeof options.bubbleErrors === "undefined") || !!options.bubbleErrors;

this._writable = writable;
  this._readable = readable;

var self = this;

writable.once("finish", function() {
    self.end();
  });

this.once("finish", function() {
    writable.end();
  });

readable.on("data", function(e) {
    if (!self.push(e)) {
      readable.pause();
    }
  });

readable.once("end", function() {
    return self.push(null);
  });

if (this._bubbleErrors) {
    writable.on("error", function(err) {
      return self.emit("error", err);
    });

readable.on("error", function(err) {
      return self.emit("error", err);
    });
  }
};
DuplexWrapper.prototype = Object.create(stream.Duplex.prototype, {constructor: {value: DuplexWrapper}});

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

DuplexWrapper.prototype._read = function _read(n) {
  this._readable.resume();
};