stream-filter
v2.1.0
Published
Filter data passed through
Downloads
5,877
Readme
stream-filter
Filter data using a through stream.
Installation
npm install stream-filter
Example
var filter = require("stream-filter");
process.stdin.pipe(filter(function(data) {
return data.length > 2;
})).pipe(process.stdout);
Async Filter Function
var filter = require("stream-filter");
process.stdin.pipe(filter.async(function(data, callback) {
doAsyncThing(data, function(err, size) {
callback(err, size > 2);
});
})).pipe(process.stdout);
API
var filter = require("stream-filter");
filter(fn, options);
filter.obj(fn, options);
filter.async(fn, options);
filter.async.obj(fn, options);
Note that filter.obj(fn)
and filter.async.obj(fn)
are convenience
wrappers to pass { objectMode: true }
.