RxJS - Error Handling - Coding Blast - www.codingblast.com

rxjs-error-retryWhen-error.ts

import {Observable} from 'rxjs';

console.log('starting');

Observable
    .of('CodingBlast', 'cuteword', 'badword', 'coding', 'blast')
    .map(w => {
        if (w === 'badword') {
            throw new Error('Bad things happen!')
        }
        return w + ' RxJS';
    })
    .retryWhen(errors => errors.delay(2000).scan(function (errorCount, err) {
        console.log('\n');
        console.log('scan inside of retryWhen. Error counter: ', errorCount);
        if (errorCount >= 3) {
            throw err;
        }

        return errorCount + 1;
    }, 1))
    .subscribe(value => console.log(value),
        err => console.error('oops, an error!', err),
        () => console.log('complete!'));