stream-messenger

Stream which bubbles message and error events.

Install

npm i @maboiteaspam/stream-messenger --save

Usage

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

• https://github.com/maboiteaspam/npi
• https://github.com/maboiteaspam/stream-message-router
• https://github.com/maboiteaspam/flower
• https://github.com/maboiteaspam/bubbler
• https://github.com/maboiteaspam/bubbled
• https://github.com/maboiteaspam/event-stream-writer