stream-filter

Filter data passed through

stream-filter

Filter data using a through stream

Example

var filter = require("stream-filter");
 
process.stdin.pipe(filter(function(data) {
return data.length > 2;
})).pipe(process.stdout);
var filter = require("stream-filter");
 
process.stdin.pipe(filter.async(function(datacallback) {
doAsyncThing(data, function(errsize) {
callback(err, size > 2);
});
})).pipe(process.stdout);

Installation

npm install stream-filter