RxJS Tutorial - Event Emitter for Node JS

rxjs-eventemitter.js

var EventEmitter = require('events').EventEmitter;
const { Observable, fromEvent } = require('rxjs');

var emitter = new EventEmitter();

var source = fromEvent(emitter, 'data');

var subscription = source.subscribe(
  (x) => console.log('Next: ' + x),
  (err) => console.log('Error: ' + err),
  () => console.log('Completed'));

emitter.emit('data', 'My 1st emitted data');
emitter.emit('data', 'My 2nd emitted data');