RXJS Angular HTTP 调用 HTTP 请求来检查互联网连接

Question

所以我使用 rxjs observables 每 30 秒调用一次 http 请求，使用间隔并重复。但是，当没有互联网连接并且 observable 调用 onError 但 observable 永远不会重复时。我也在使用 retryWhen 并且它不起作用

有什么建议吗？

这是我的代码

   Observable.interval(2500).repeat()
      .flatMap(() => this.http.get(url))
      .map(res => res.text())
      .catch(() => {
        return Observable.of('ERROR');
      })
      .retryWhen(error => error)
      .subscribe(data => {
          // tools.destroyLoadingMessage();
          alert('CONNECT OBSEVABLE ' + data);

         // console.log(JSON.stringify(data));
      }, err => {
        alert('DISCONNECT OBSEVABLE ' + err);
        // tools.showLoadingMessage('No inrernet');
      })

Answer 1

为避免在请求失败时破坏 observable，您必须从请求中捕获错误，以便流可以继续。

当出现错误时，您将看到value: error，否则将是服务器的响应。

Rx.Observable.interval(2500)
  .flatMap(() => {
    return this.http.get(url)
      .catch(error => Rx.Observable.of('error'))
  })
  .subscribe(
    value => console.log('value: ' + value),
    err => console.log('error'),
    () => console.log('complete')
  );