stream-filter
Filter data passed through
Last updated 4 years ago by parshap .
Public Domain · Repository · Bugs · Original npm · Tarball · package.json
$ cnpm install stream-filter 
SYNC missed versions from official npm registry.

stream-filter

Filter data using a through stream.

build status

Installation

npm: stream-filter

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 }.

See index.js and test.js for API details.

Current Tags

  • 2.1.0                                ...           latest (4 years ago)

3 Versions

  • 2.1.0                                ...           4 years ago
  • 2.0.0                                ...           4 years ago
  • 1.0.0                                ...           7 years ago

Copyright 2014 - 2017 © taobao.org |