import {merge} from "rxjs/observable/merge";
import {Subject} from "rxjs/Subject";
import {Observable} from "rxjs/Observable";

const subOdd: Subject<number> = new Subject<number>();
const subEven: Subject<number> = new Subject<number>();

const mergedObservable: Observable<number> = merge(subEven, subOdd);
mergedObservable.subscribe((value: number) => {
    console.log(value);
}, () => {
    console.log('will error out if one of the observables errors')
});

subOdd.next(1);
subOdd.next(3);
subOdd.next(5);

subEven.next(0);
subEven.next(2);
subEven.next(4);

subOdd.error(new Error('Yet another error'));