-

var Rx = require('rx');

var subjects = {};

function create(sn) {

    var s = new Rx.Subject();

    subjects[sn] = s;

    return Rx.Observable.create(function (o) {

        var so = s.asObservable();

        so.forEach(o.onNext.bind(o), o.onError.bind(o), o.onCompleted.bind(o));

        return function () {
            console.log('dispose %s', sn);
        }
    });
}

var o = create(1);

var c = console.log.bind(console);

var t = o.forEach(c, c, function () {
    console.log('complete');
});

Rx.Observable.merge(
    create(2),
    create(3),
    create(4)
    ).
    takeUntil(create(5)).
    forEach(c, c, function () {
        console.log('completed');
    });

subjects[5].onNext();