node package manager
Share your code. npm Orgs help your team discover, share, and reuse code. Create a free org »

mapping-stream

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