summaryrefslogtreecommitdiff
path: root/deps/node/deps/npm/node_modules/stream-each/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/node/deps/npm/node_modules/stream-each/index.js')
-rw-r--r--deps/node/deps/npm/node_modules/stream-each/index.js58
1 files changed, 0 insertions, 58 deletions
diff --git a/deps/node/deps/npm/node_modules/stream-each/index.js b/deps/node/deps/npm/node_modules/stream-each/index.js
deleted file mode 100644
index 7e67f733..00000000
--- a/deps/node/deps/npm/node_modules/stream-each/index.js
+++ /dev/null
@@ -1,58 +0,0 @@
-var eos = require('end-of-stream')
-var shift = require('stream-shift')
-
-module.exports = each
-
-function each (stream, fn, cb) {
- var want = true
- var error = null
- var ended = false
- var running = false
- var calling = false
-
- stream.on('readable', onreadable)
- onreadable()
-
- if (cb) eos(stream, {readable: true, writable: false}, done)
- return stream
-
- function done (err) {
- if (!error) error = err
- ended = true
- if (!running) cb(error)
- }
-
- function onreadable () {
- if (want) read()
- }
-
- function afterRead (err) {
- running = false
-
- if (err) {
- error = err
- if (ended) return cb(error)
- stream.destroy(err)
- return
- }
- if (ended) return cb(error)
- if (!calling) read()
- }
-
- function read () {
- while (!running && !ended) {
- want = false
-
- var data = shift(stream)
- if (data === null) {
- want = true
- return
- }
-
- running = true
- calling = true
- fn(data, afterRead)
- calling = false
- }
- }
-}