RxJS test

index.js

var Rx = require('rx');

// Fake Mongo writing

var db = {
    insert: function(x) {
        console.log('Write to Mongo value impl: ' + x.key);
    }
};

function myEventCollector(eventSource) {
    
    var source = Rx.Observable.fromEvent(eventSource, 'message')
        .groupByUntil(function(x) {return x.release;},
                      function(x) {return x.release;},
                      function(x) {return Rx.Observable.timer(10000);});

    var subscription = source.subscribe(function(obs) {
        obs.count().subscribe(function(x) {
            console.log('count: ' + x);
            db.insert(x);
        });
    });
}

function myBrilliantFunction() {
    var source = Rx.Observable.interval(1000)
        .take(5)
        .sum();

    var subscription = source.subscribe(
        function (x) {
            db.insert(x);
        },
        function (err) {
            console.log('Error: ' + err);
        },
        function () {
            console.log('Completed');
        }
    );
}

module.exports.myEventCollector = myEventCollector;
module.exports.myBrilliantFunction = myBrilliantFunction;