aboutsummaryrefslogtreecommitdiff
path: root/node_modules/duplexer2/index.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
commitcc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch)
tree92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/duplexer2/index.js
parent3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff)
remove node_modules
Diffstat (limited to 'node_modules/duplexer2/index.js')
-rw-r--r--node_modules/duplexer2/index.js62
1 files changed, 0 insertions, 62 deletions
diff --git a/node_modules/duplexer2/index.js b/node_modules/duplexer2/index.js
deleted file mode 100644
index b8fafcb3f..000000000
--- a/node_modules/duplexer2/index.js
+++ /dev/null
@@ -1,62 +0,0 @@
-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();
-};