Skip to content

RangerMauve/through2-map-promise

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

3 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

through2-map-promise

A small promise-based wrapper for through2. Allows you to easily map over data in a stream while using promises for flow control.

Quickstart

npm install --save through2-map-promise
var map = require("through2-map-promise");
var xtend = require("xtend");

// in an HTTP request handler
db.users.find({}).pipe(map.obj(function(user){
    var locationId = user.location;
    return db.locations.findOne({_id: locationId}).then(function(location){
        return xtend(user, {
            location: location
        });
    });
})).pipe(response);

API

through2-map-promise([options,] [fn])

Creates a transform stream which calls your transforming function, fn. You can throw within your function to automatically reject the promise and error-out the stream. options is the optional object that gets passed into through2.

through2-map-promise.obj([options,] [fn])

Same as the former, but the stream is created in objectMode

through2-map-promise.ctor([options,] [fn])

Creates a constructor for your transform stream in case you want to be more efficient

About

A small promise-based wrapper for through2

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published