관리-도구

편집 파일: index.js

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 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) read() } function read () { if (ended || running) return want = false var data = shift(stream) if (!data) { want = true return } running = true fn(data, afterRead) } }