import Rx from 'rx';
import InjectableObservable from 'rx-injectable-observable';
 
let sum$ = InjectableObservable((x$, y$) =>
    Rx.Observable.combineLatest(x$, y$,
        (x, y) => x + y
    )
);
 
sum$.subscribe((x) => {
    assert(x, 15);
});
 
// you can inject dependencies before and after subscription
sum$.inject(
    Rx.Observable.just(9),
    Rx.Observable.just(6)
);
 
setTimeout(() => {
    sum$.dispose(); // and after some time remove underlying subscriptions
}, 1000);
 
// you can also inject stream to itself
let double$ = new InjectableObservable((x$) => x$.map((x) => x * 2));
 
double$.inject(double$.startWith(1));
 
double$.elementAt(4).subscribe((x) => {
    assert.equal(x, 32);
});