stream-iterate

Iterate through the values in a stream.

npm install stream-iterate

Usage

var iterate = require('stream-iterate')
var from = require('from2')
 
var stream = from.obj(['a', 'b', 'c'])
 
var read = iterate(stream)
 
loop()
 
// recursively iterates through each item in the stream
function loop () {
  read(function (err, data, next) {
    console.log(err, data)
    next()
    loop()
  })
}

If you don't call next and call read again the same (err, value) pair will be returned.

You can use this module to implement stuff like a streaming merge sort.

License

MIT