diff options
author | Florian Dold <florian.dold@gmail.com> | 2019-03-27 21:01:33 +0100 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2019-03-27 21:01:33 +0100 |
commit | cc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch) | |
tree | 92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/stream-to-array/index.js | |
parent | 3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff) |
remove node_modules
Diffstat (limited to 'node_modules/stream-to-array/index.js')
-rw-r--r-- | node_modules/stream-to-array/index.js | 60 |
1 files changed, 0 insertions, 60 deletions
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 -} |