0readme.md

Chain streams

Chain streaming operations together

Example

// Create a chaining stream based on a stream of todo data chunks
chain(todos)
    // Map them through a Todo constructor
    .map(Todo)
    // pluck the elements.root property
    .pluck("elements.root")
    .forEach(function (elem) {
        todoList.appendChild(elem)
    })

chain.js

var map = require("lazy-map-stream")
    , forEach = require("forEach-stream")
    , pluck = require("pluck-stream")

module.exports = chain

function chain(stream) {
    var curr = stream
        , self = {
            map: apply(map)
            , forEach: apply(forEach)
            , pluck: apply(pluck)
        }

    return self

    function apply(f) {
        return function () {
            var args = [].slice.call(arguments)
                , args.unshift(curr)
                
            curr = f.apply(null, args)

            return self
        }
    }
}