Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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();
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement