mapping-stream v0.1.0

mapping-stream

Turn an asynchronous function into a through stream

Example

var from = require("read-stream").fromArray
    , to = require("write-stream").toArray

    , map = require("mapping-stream")

from([1,2,3])
    .pipe(map(function (item, cb) {
        setTimeout(function() {
            cb(null, item * 2)
        }, 1000);
    }))
    .pipe(map(function (item) {
        return item * 2
    }))
    .pipe(to([], function toList (list) {
        console.log("list", list)
    }))

Installation

npm install mapping-stream

Contributors

• Raynos

MIT Licenced