It's just a wrapper to build Stream transformers with functional style. It's like the koa / expressjs middlewares !
const ezs = require('ezs')
ezs.use(require('ezs-basics'));
process.stdin.resume();
process.stdin.setEncoding('utf8');
process.stdin
.pipe(ezs('split', { delimiter: "\n" }))
.pipe(ezs('counter'))
.pipe(ezs((input, output) => output.send(input.toString()));
.pipe(process.stdout);
With npm:
$ npm install ezs
Use mocha to run the tests.
$ npm install mocha
$ mocha test
Each statement function have its own scope and can access to few methods :
Output object is an object with few methods :
With a sync statement, you can break the pipe with throw but with an async statement, you should use stop(with An Error) instead of throw.
Each statement can be executed in different modes :
The basic way to use modes, it's with a ezs script or with ezs.dispatch function.
Converts a transform stream with existing function or adhoc function.
const ezs = require('ezs'),
let transformer = ezs(function(input, output) {
output.send(input.toString())
})
Adding bundle of statements. see the avaible modules here : https://www.npmjs.com/browse/keyword/ezs
import ezs from 'ezs';
import basics from 'ezs-basics';
import files from 'ezs-files';
ezs.use(basics);
ezs.use(files);
To set globaly a statement parameter.
Launch a serie of statements.
Launch, through a server, a serie of statements.
Parse an .ini string to extract global keys and values.
Parse an .ini file to extract global keys and values.
Parse an .ini string and return Object contains a serie of statements
Parse an .ini string and launch a serie of statements
Parse an .ini file and return Object contains a serie of statements
Parse an .ini file and launch a serie of statements
catch Error in NodeJS pipeline
get chunk of in NodeJS pipeline and send Buffer of the chunk
To cache the result of the pipeline. Options:
max Number max items in the cache (optional, default 500)maxAge Number max age of items in the cache (optional, default 360000)objectMode Boolean cache for object (or Buffer) (optional, default false)Example:
const cache = ezs.createCache({ objectMode: false });
const cacheID = 'XXXXXX';
const cached = cache1.get(cacheID);
if (cached) {
cached
.pipe(process.stdout)
} else {
process.stdin
.pipe(cache1.set(cacheID))
.pipe(process.stdout)
}
To create a Passthru stream.
Example:
const input = ezs.createStream();
input.pipe(process.stdout);
input.write('Hello');
input.end();
Save a Object streams to the filesystem.
Example:
const input = ezs.createStream(ezs.objectMode());
input.pipe(ezs.save('/tmp/db'));
input.write({ text: 'Hello' });
input.write({ text: 'World' });
input.end();
Load a Object streams from the filesystem. (saved by ezs.save function)
Example:
const input = ezs.load('/tmp/db');
.pipe(process.stdout)
Compress a binary stream.
Example:
process.stdin
.pipe(ezs.compress())
.pipe(process.stdout)
;
Uncompress a binary stream. (compressed by ezs.compress function)
Example:
process.stdin
.pipe(ezs.uncompress())
.pipe(process.stdout)
;
Launch a server for ezs.dispatch
Launch a cluster for ezs.dispatch
Take Object and add new field
Returns Object
Take all String, concat them and thow just one
datafeedbeginWith String? Add value at the beginjoinWith String? use value to join 2 chunkendWith String? Add value at the endReturns String
Take Object , print it and throw the same object
datafeedlevel String console level : log or error (optional, default log)text String text before the dump (optional, default valueOf)path String? path of field to printReturns Object
Take all Object and genereta a json array
datafeedindent String indent JSON (optional, default false)Returns String
Take Object and send the same object
but in the meantime, it is possible to add
new environment field
Returns Object
Take Object and throw each value of fields
datafeedpath String? path of field to extractReturns Object
Take all chunk, and throw array of chunks
datafeedsize Number? Size of each partitionReturns String
Take Object and throw the same object but keep only
spefici fields
datafeedpath String? path of field to keepReturns Object
Take all Object, throw encoded String
datafeedReturns String
Take Object and create a new object with some fields
Returns Object
Take the first Object and close the feed
datafeedReturns Object
Take Object, shuffle data of the whole object or only some fields specified by path
datafeedpath String? path of field to shuffleReturns Object
Take Object and throw the same object
datafeedReturns Object
Take all chunk, and throw each item of chunks
datafeedReturns String
Take String and throw Object builded by JSON.parse on each line
datafeedReturns String
FAQs
A wrapper to build Stream transformers with functional style
The npm package ezs receives a total of 91 weekly downloads. As such, ezs popularity was classified as not popular.
We found that ezs demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
/Research
Socket found a Rust typosquat (finch-rust) that loads sha-rust to steal credentials, using impersonation and an unpinned dependency to auto-deliver updates.
Research
/Security Fundamentals
A pair of typosquatted Go packages posing as Google’s UUID library quietly turn helper functions into encrypted exfiltration channels to a paste site, putting developer and CI data at risk.
Security News
November CVE publications fell 25% YoY even as 2025 totals rose, showing how a few major CNAs can swing “global” counts and skew perceived risk.