1 files changed, 49 insertions, 0 deletions
diff --git a/node_modules/stream-to-array/index.js b/node_modules/stream-to-array/index.js
new file mode 100644
index 000000000..76fcd1fc6
--- /dev/null
+++ b/node_modules/stream-to-array/index.js
@@ -0,0 +1,49 @@
+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
+  }
+
+  // if stream is already ended,
+  // return an array
+  if (!stream.readable) {
+    process.nextTick(function () {
+      done(null, [])
+    })
+    return defer
+  }
+
+  var arr = []
+
+  stream.on('data', onData)
+  stream.once('end', onEnd)
+  stream.once('error', onEnd)
+  stream.once('close', cleanup)
+
+  return defer
+
+  function defer(fn) {
+    done = fn
+  }
+
+  function onData(doc) {
+    arr.push(doc)
+  }
+
+  function onEnd(err) {
+    done(err, arr)
+    cleanup()
+  }
+
+  function cleanup() {
+    arr = null
+    stream.removeListener('data', onData)
+    stream.removeListener('end', onEnd)
+    stream.removeListener('error', onEnd)
+    stream.removeListener('close', cleanup)
+  }
+}
+\ No newline at end of file