munchy v1.0.9

munchy

A producer Node stream for draining different data, including Readable streams.

$ npm i --save munchy

examples:

const Munchy = require("munchy");
const munchy = new Munchy();
munchy.munch("hello world", fs.createReadStream("blah"), "bye bye");
munchy.munch(null); // null terminates it
munchy.pipe(process.stdout);

const Munchy = require("munchy");
const munchy = new Munchy({}, fs.createReadStream("foo"), fs.createReadStream("bar"));
munchy.munch(fs.createReadStream("blah"), "bye bye", null); // null terminates it
munchy.pipe(process.stdout);

API

constructor

Munchy(opts, ...sources);

Munchy specific options:

handleStreamError should take the error object and return an object with these fields:

If handleStreamError returns a falsy value, then Munchy will emit the error and destroys itself.

For example:

const munchy = new Munchy({
  handleStreamError: err => {
    return { result: err.stack, remit: false };
  }
});

munch

munchy.munch(...sources);

• Returns this.

• To end and terminate munchy stream:

munchy.munch(null);

Events

Munchy emits the following custom events:

ie:

munchy.on("draining", ({ stream }) => {});

Demos

• Hapi - https://github.com/jchip/hapi-stream-sample
• Koa - https://github.com/jchip/koa-stream-sample
• express - https://github.com/jchip/express-stream-sample

License

Licensed under the Apache License, Version 2.0