aboutsummaryrefslogtreecommitdiff
path: root/node_modules/stream-to-array/index.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2016-10-10 03:43:44 +0200
committerFlorian Dold <florian.dold@gmail.com>2016-10-10 03:43:44 +0200
commitabd94a7f5a50f43c797a11b53549ae48fff667c3 (patch)
treeab8ed457f65cdd72e13e0571d2975729428f1551 /node_modules/stream-to-array/index.js
parenta0247c6a3fd6a09a41a7e35a3441324c4dcb58be (diff)
downloadwallet-core-abd94a7f5a50f43c797a11b53549ae48fff667c3.tar.xz
add node_modules to address #4364
Diffstat (limited to 'node_modules/stream-to-array/index.js')
-rw-r--r--node_modules/stream-to-array/index.js49
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