//emit value every 200ms

const source = Rx.Observable.interval(200);

​

//output the observable

const main = source

    .map(val => {

        if (val > 5) {

            throw new Error('The request failed somehow.');

        }

        return val;

    })

    .retryWhen(errors => errors

        //log error message

        .do(val => console.log(`Some error that occur ${val}, pauze for 30 seconds.`))

    );

​

const retry = main

    .map(val => {

        if (val > 5) {

            throw new Error('The request failed somehow.');

        }

        return val;

    })

    .retryWhen(errors => errors

        //log error message

        .do(val => console.log(`Some error that occur ${val}, pauze for 30 seconds.`))

​

        //restart in 30 seconds

        .delayWhen(val => Rx.Observable.timer(30 * 1000))

    );

​

const subscribe = retry

    .subscribe({

        next: val => console.log(val),

        error: val => console.log(`This will never happen`)

    });

​