Как предотвратить остановку Observable?

Question

[dev-executor]

Есть такой код, в случае ошибки интервал прекращается, и observable становится выполненым, как это предотвратить?

Observable.interval(3000)
            .do(value => console.log('attempt #', value))
            .switchMap(() => this.http.get(url))
            .catch (err => Observable.empty())
            .subscribe(data => console.log(data));

Answer 1

[davidnum95]

Нужно внутри switchMap создать новый Observable который будет перехватывать ошибку:

Observable.interval(3000)
            .do(value => console.log('attempt #', value))
            .switchMap(() => Observable.defer(() => this.http.get(url))
                  .map(data => data)
                  .catch(err => console.log(err))
            )
            .catch (err => Observable.empty())
            .subscribe(data => console.log(data));