Rx.Observable.spawn

[unao]

It is really nice to see spawn in the rxjs - unfortunately it seems that error handling does not work.

rx.js 4.0.0

var s = Rx.Observable.spawn(function *(){

    try {
        var err1 = yield Rx.Observable.throw('1');
        console.log('ERR_1', err1);
        var err2 = yield Promise.reject('2');
        console.log('ERR_2', err2);
    }
    catch(ex){
        // never called
        console.error('ERROR_RX_JS', ex);
    }

});

s.subscribe(
    _=>_,
    (err)=>console.log(err),
    ()=>console.log('completed')
);

Output:

ERR_1 1
ERR_2 2
completed

For comparison:

co 4.6.0

co(function *(){
    try {
        var err1 = yield Rx.Observable.throw('1')
            .toPromise();
        console.log('ERR_1', err1);
        var err2 = yield Promise.reject('2');
        console.log('ERR_2', err2);
    }
    catch(ex){
       // here `err1` is undefined
        console.error('ERROR_CO', ex);
    }
});

Output:

ERROR_CO 1

[mattpodwysocki]

@unao fixed as per 3652801 where fromPromise would swallow errors.