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/stream-to-array/index.js | 60 ----------------------------------- 1 file changed, 60 deletions(-) delete mode 100644 node_modules/stream-to-array/index.js (limited to 'node_modules/stream-to-array/index.js') diff --git a/node_modules/stream-to-array/index.js b/node_modules/stream-to-array/index.js deleted file mode 100644 index 2d6aaa0fb..000000000 --- a/node_modules/stream-to-array/index.js +++ /dev/null @@ -1,60 +0,0 @@ - -var Promise = require('any-promise') - -module.exports = function (stream, done) { - if (!stream) { - // no arguments, meaning stream = this - stream = this - } else if (typeof stream === 'function') { - // stream = this, callback passed - done = stream - stream = this - } - - var deferred - if (!stream.readable) deferred = Promise.resolve([]) - else deferred = new Promise(function (resolve, reject) { - // stream is already ended - if (!stream.readable) return resolve([]) - - var arr = [] - - stream.on('data', onData) - stream.on('end', onEnd) - stream.on('error', onEnd) - stream.on('close', onClose) - - function onData(doc) { - arr.push(doc) - } - - function onEnd(err) { - if (err) reject(err) - else resolve(arr) - cleanup() - } - - function onClose() { - resolve(arr) - cleanup() - } - - function cleanup() { - arr = null - stream.removeListener('data', onData) - stream.removeListener('end', onEnd) - stream.removeListener('error', onEnd) - stream.removeListener('close', onClose) - } - }) - - if (typeof done === 'function') { - deferred.then(function (arr) { - process.nextTick(function() { - done(null, arr) - }) - }, done) - } - - return deferred -} -- cgit v1.2.3