summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js
diff options
context:
space:
mode:
authorFallenRiteMonk <fallenritemonk@gmail.com>2018-04-05 11:52:34 -0400
committerMyles Borins <mylesborins@google.com>2018-04-05 16:01:07 -0400
commit25a816dcda7b1db0929501acfe13f2fe5119759b (patch)
treed3df4377a11dfb643b5976d2048d9bb4ee527903 /deps/npm/node_modules/mississippi/node_modules/stream-each/index.js
parentb29c36b80746733994257b7380245102bc3c4cd6 (diff)
downloadandroid-node-v8-25a816dcda7b1db0929501acfe13f2fe5119759b.tar.gz
android-node-v8-25a816dcda7b1db0929501acfe13f2fe5119759b.tar.bz2
android-node-v8-25a816dcda7b1db0929501acfe13f2fe5119759b.zip
deps: upgrade npm to 5.8.0
PR-URL: https://github.com/nodejs/node/pull/19560 Fixes: https://github.com/nodejs/node/issues/19271 Reviewed-By: Michaƫl Zasso <targos@protonmail.com> Reviewed-By: Myles Borins <myles.borins@gmail.com>
Diffstat (limited to 'deps/npm/node_modules/mississippi/node_modules/stream-each/index.js')
-rw-r--r--deps/npm/node_modules/mississippi/node_modules/stream-each/index.js26
1 files changed, 15 insertions, 11 deletions
diff --git a/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js b/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js
index 2c07e957a3..7e67f7337a 100644
--- a/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js
+++ b/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js
@@ -8,6 +8,7 @@ function each (stream, fn, cb) {
var error = null
var ended = false
var running = false
+ var calling = false
stream.on('readable', onreadable)
onreadable()
@@ -35,20 +36,23 @@ function each (stream, fn, cb) {
return
}
if (ended) return cb(error)
- read()
+ if (!calling) read()
}
function read () {
- if (ended || running) return
- want = false
-
- var data = shift(stream)
- if (!data) {
- want = true
- return
+ while (!running && !ended) {
+ want = false
+
+ var data = shift(stream)
+ if (data === null) {
+ want = true
+ return
+ }
+
+ running = true
+ calling = true
+ fn(data, afterRead)
+ calling = false
}
-
- running = true
- fn(data, afterRead)
}
}