❤
npm
Sign UpSign In

event2stream

0.1.2 • Public • Published

Travis CI

event2stream

Overview

A module that transforms an EventEmitter into a ReadableStream. Internally to the module this is accomplished by keeping a buffer in memory. Future releases will include the ability to use other forms of buffering.

The module was created to satify an easy way to test other modules that consume readable streams. Rather than requiring the use of fs.createReadStream or similar, this module allows for any a custom readable stream to be implemented easily.

Examples

Example: Convert log events into a stream and connect the stream to stdout.

const events = require( "events" );
const event2stream = require( "event2stream" );
 
const myEventEmitter = new events.EventEmitter( );
const eventStream = new event2stream( {
    eventEmitter: myEventEmitter,
    eventNames: [ "log" ]
} );
 
eventStream.pipe( process.stdout );
 
myEventEmitter.emit( "log", "This is a log message." );
myEventEmitter.emit( "log", "Another log message" );
 
setTimeout( function( ){
    eventStream.die();
}, 1500 );

Example: Sample event to stream conversion using an object stream. Demonstrates the pause() and resume() functionality.

const events = require( "events" );
const event2stream = require( "event2stream" );
 
const myEventEmitter = new events.EventEmitter( );
const eventStream = new event2stream( {
    eventEmitter: myEventEmitter,
    eventNames: [ "hey" ],
    mode: "object"
} );
 
eventStream.pause( );
 
eventStream.on( "data", function( data ){
    console.log( data ); // { "eventName": "hey", "data": { "This": "is", data: 1 }
 
    eventStream.die( );
} );
 
myEventEmitter.emit( "hey", { "This": "is", data: 1 } );
 
setTimeout( function( ){
    eventStream.resume();
}, 1000 );

Readme

Keywords

none

Package Sidebar

Install

npm i event2stream

Weekly Downloads

0

Version

0.1.2

License

none

Last publish

Collaborators

  • robertkeizer
Try on RunKit
Report malware