observables-test.js

observables-test.js

        console.log('Observables experiment...');
        const ob1 = Observable.create((observer: Observer<number>) => {
            observer.next(1);
            observer.next(2);
            observer.complete();
        });
        const ob2 = num => {
            return Observable.create((observer: Observer<number>) => {
                console.log(`from num ${num}`);
                observer.next(4);
                observer.next(5);
                observer.next(6);
                observer.complete();
            });
        };
        ob1.mergeMap(ob2).subscribe(
            num => console.log(num),
            e => console.log(e),
            () => console.log('completed'),
        );