gen-stream

Pull streams with generators

Usage

const pull = require('pull-stream')
const genStream = require('gen-stream')
pull(
    genStream.source(function*() {
        yield 1
        yield 2
        yield 3
    }),
    genStream.through(function*(read) {
        while(true) {
            var input = yield read()
            if(!input) break
            yield input + input / 10
        }
    }),
    genStream.sink(function*(read) {
        while(true) {
            var input = yield read()
            if(!input) break
            console.log(input)
        }
    })
)
 
// =>
//  1.1
//  2.2
//  3.3

API

genStream.source(generator) - Creates a source from generator genStream.through(generatorFn) - Creates a through stream from generatorFn genStream.sink(generatorFn) - Creates a sink from generatorFn