Nominating Presidential Muppets
    Have ideas to improve npm?Join in the discussion! »

    cascade-stream

    0.2.3 • Public • Published

    cascade-stream

    NPM

    Travis

    A duplex stream that can lazily create child streams from a chunk and merge all outputs into one

    example

    var from = require('from2-array')
    var through = require('through2')
    var cascade = require('cascade-stream')
     
    // create a stream for a single letter
    function createLetterStream(letter){
        return from.obj([1,2,3].map(function(num){
            return letter + ':' + num
        }))
    }
     
    var source = from.obj(['a', 'b', 'c'])
     
    var pipeline = cascade(function(chunk, add, next){
        add(createLetterStream(chunk))
        next()
    })
     
    var sink = through.obj(function(chunk, enc, cb){
        console.log(chunk);
        cb()
    })
     
    source.pipe(pipeline).pipe(sink)
    /*
     
        a1
        a2
        a3
        b1
        b2
        b3
        c1
        c2
        c3
        
    */

    license

    MIT

    Install

    npm i cascade-stream

    DownloadsWeekly Downloads

    5

    Version

    0.2.3

    License

    MIT

    Last publish

    Collaborators

    • avatar