mapping-stream

0.1.0 • Public • Published

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

Readme

Keywords

none

Package Sidebar

Install

npm i mapping-stream

Weekly Downloads

3

Version

0.1.0

License

none

Last publish

Collaborators

  • raynos