diff options
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 -} |