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

rxjs-throw-error-retryWhen.ts

import {Observable} from 'rxjs';

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(5000).take(1))
    .subscribe(value => console.log(value),
        err => console.error('oops, an error!', err),
        () => console.log('complete!'));