From abd94a7f5a50f43c797a11b53549ae48fff667c3 Mon Sep 17 00:00:00 2001
From: Florian Dold <florian.dold@gmail.com>
Date: Mon, 10 Oct 2016 03:43:44 +0200
Subject: add node_modules to address #4364

---
 node_modules/stream-to-array/index.js | 49 +++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create 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
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
-- 
cgit v1.2.3