rxjs - 只有当它返回的速度比延迟快时，我才能延迟一个可观察的

Question

举个例子：

 this.http.get('/getdata').pipe(delay(2000))

我希望此请求至少需要 2 秒才能完成，但不会超过完成请求所需的时间。

换句话说：

1. 如果请求需要1s完成，我希望 observable 在2s完成。

2. 如果请求需要3s完成，我希望 observable 在3s NOT 5s内完成。

是否有其他管道delay()可以实现我不知道的这一点，或者是否有办法为此构建自定义管道？

用例是显示一个加载器，但是如果请求完成得太快，当加载器只是“闪烁”一秒钟时，它看起来并不好

Answer 1

要回答所问的问题，您可以简单地使用combineLatest()将timer(2000)observable 和 request observable 结合起来，然后忽略来自 timer observable 的结果。它之所以有效，是因为combineLatest要等到所有可观察对象都发出至少一个值，然后再发出一个值。

combineLatest(this.http.get('/getdata'), timer(2000), x => x)

Answer 2

感谢 GregL，我将其更新为仅使用 forkJoin。这将获得流的最新值。但是如果你想在每次发射时检查它，你可以用 combineLatest 替换 forkJoin ，这也可以。在我的工作示例中：

    this.ibanSubscription = forkJoin({
        iban: this.ibantobicService.getById(Iban),
        timer: timer(1000) //so now the ajax call will take at least 1 second 
        }
    ).pipe(
        map( (stream: any) => <BicModel>stream.iban),
        switchMap( (bic: BicModel) => of(this.processIbanData(bic))),
        catchError((error: any) => of(this.messageList.handleError(error))),
        finalize(() => this.loadIbanToBicFinalize())
   ).subscribe();