2.0.0 • Published 8 years ago
@maboiteaspam/stream-messenger v2.0.0
stream-messenger
Stream which bubbles message and error events.
Install
npm i @maboiteaspam/stream-messenger --saveUsage
var eventStream = require('@maboiteaspam/event-stream-writer')
var streamMsger = require('@maboiteaspam/stream-messenger')
var streamA = streamMsger('streamA'); // Let s say there 2 stream-messenger,
var streamB = streamMsger('streamB');
// which bubbles 'message' events,
streamA.pipe(streamB) // when they are piped together.
//
// Now, let s say you want to process,
var streamC = streamMsger('streamC'); // all those bubbled events into a new stream.
//
var writer = eventStream('message', streamA); // With event-stream-writer
// transform bubbled 'message' events
writer.pipe(streamC); // back into piped data of streamC
streamC.on('data', function (d) { // streamC now re-emits
console.log(d + ', from streamC !') // streamB 'message' events
}); // as a regular 'data' event.
streamB.emit('message', 'hello it s streamB') // - emit a 'message' event from streamB,
// because it s a stream-messenger,
// it bubbles-up the event to streamA.
// - streamA re emits into streamC,
// streamC process streamB's events via streamA.
//More
You can see it in action in npi
2.0.0
8 years ago