aboutsummaryrefslogtreecommitdiff
path: root/node_modules/stream-to-array/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/stream-to-array/index.js')
-rw-r--r--node_modules/stream-to-array/index.js60
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
-}