diff options
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.js | 58 |
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 - } - } -} |