From cc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 Mon Sep 17 00:00:00 2001 From: Florian Dold Date: Wed, 27 Mar 2019 21:01:33 +0100 Subject: remove node_modules --- node_modules/multipipe/index.js | 72 ----------------------------------------- 1 file changed, 72 deletions(-) delete mode 100644 node_modules/multipipe/index.js (limited to 'node_modules/multipipe/index.js') diff --git a/node_modules/multipipe/index.js b/node_modules/multipipe/index.js deleted file mode 100644 index 5e406db88..000000000 --- a/node_modules/multipipe/index.js +++ /dev/null @@ -1,72 +0,0 @@ - -/** - * Module dependencies. - */ - -var duplexer = require('duplexer2'); -var Stream = require('stream'); - -/** - * Slice reference. - */ - -var slice = [].slice; - -/** - * Duplexer options. - */ - -var opts = { - bubbleErrors: false -}; - -/** - * Expose `pipe`. - */ - -module.exports = pipe; - -/** - * Pipe. - * - * @param {Stream,...,[Function]} - * @return {Stream} - * @api public - */ - -function pipe(){ - if (arguments.length == 1) return arguments[0]; - var streams = slice.call(arguments); - var cb; - if ('function' == typeof streams[streams.length - 1]) { - cb = streams.splice(-1)[0]; - } - var first = streams[0]; - var last = streams[streams.length - 1]; - var ret; - - if (first.writable && last.readable) ret = duplexer(opts, first, last); - else if (first.writable) ret = first; - else if (last.readable) ret = last; - else ret = new Stream; - - streams.forEach(function(stream, i){ - var next = streams[i+1]; - if (next) stream.pipe(next); - if (stream != ret) stream.on('error', ret.emit.bind(ret, 'error')); - }); - - if (cb) { - var ended = false; - ret.on('error', end); - last.on('finish', end); - function end(err){ - if (ended) return; - ended = true; - cb(err); - } - } - - return ret; -} - -- cgit v1.2.3