angular - Rxjs 重试延迟功能

Question

我正在尝试将 retry 与 delay 函数一起使用，我希望函数将在 1000 毫秒延迟后调用，但它不会，这里可能有什么错误？查看控制台输出，时间是 16:22:48。

我预计 16:22:48、16:22:59 ...

canCreate: boolean;
getSomeFunction(): Observable<boolean> {
        return new Observable<boolean>(
            observer => {
                const canCreate = null; // this is just null for now, will some value later
                if (canCreate == null) {
                    observer.error('error');
                } else {
                    observer.next(true);
                }
                observer.complete();
            }
        )
    }


this.getSomeFunction()
      .do((value) => {
        this.cCreate = value;
      }, (error) => {
         console.log(error + new Date().toTimeString());
      })
      .delay(1000)
      .retry(10)
      .subscribe(
        value => this.cCreate = value,
        error => {
          this.cCreate = false;
        },
        () => {}
      );
  }

控制台结果是:

Answer 1

delay()用于在可观察对象发出的事件之间引入延迟。但是可观察对象从不发出任何事件。它只是立即出错。

您要找的是retryWhen() ，它允许决定在多长时间后重试:

RxJS 5:

  .retryWhen(errors => errors.delay(1000).take(10))

RxJS 6:

import { retryWhen, delay, take } from 'rxjs/operators'
someFunction().pipe(
  // ...
  retryWhen(errors => errors.pipe(delay(1000), take(10)))
)

这将在 10 次尝试后完成整个 observable。如果你想在 10 次尝试后让整个 observable 出错，retryWhen 回调返回的 observable 必须抛出:

RxJS 5:

  .retryWhen(errors => errors.delay(1000).take(10).concat(Observable.throw()))

RxJS 6:

import { retryWhen, delay, take, concatMap, throwError } from 'rxjs/operators'
someFunction().pipe(
  // ...
  retryWhen(errors => errors.pipe(delay(1000), take(10), concatMap(throwError)))
)