Using Node.js EventEmitter and Reactive Programming for a Perpetual Eventloop

reactiveEventLoop.js

var Rx = require('rx'),
  EventEmitter = require('events').EventEmitter,
  i = 0;

var eventEmitter = new EventEmitter();

var source = Rx.Observable.fromEvent(eventEmitter, 'data')

var subscription = source.subscribe(function(data) {
  process.nextTick(function() {
    i++;
    console.log('data: ' + data);
    eventEmitter.emit('data', i);
  });
});

eventEmitter.emit('data', i);