simple script to run node js app with reactive extensions

hello-rx.js

const Rx = require('rx');

const sequence = Rx.Observable.create(function(src) {
    src.onNext(1);
    src.onNext(2);
    src.onNext(3);
    src.onNext(4);
    src.onError(new Error("booom!!!"));
    src.onNext(5);
    src.onCompleted();
});

/*
const sequence = Rx.Observable.just('hello''));
const sequence = Rx.Observable.throw(new Error('boom!'));
*/

sequence.subscribe(
    msg => console.log(`message: ${msg}`),
    ex => console.log(`error: ${ex}`),
    () => console.log("finished!")
);