Angular / RxJS：发送 API 请求然后轮询另一个端点

Question

我想发送一个 API 请求，然后轮询另一个端点，直到带有 success: true 正文的响应从第二个端点返回。我正在使用 Angular 的 HTTPClient 来提出我的请求。我最初的想法是这样做：

createConversion(request): Observable<any> {
    return this.http.post('/endpoint', request).pipe(

      // This is the problem: I want to start polling before this post() call emits

      mergeMap((response) => {

        // Start polling

        return timer(0, 5000).pipe(
          takeUntil(this.converted$),
          concatMap(() => {

            return this.http.get('/second-endpoint')
          })
        )
      })
    );

但是，直到第一个 post() 调用与第一个请求的响应一起发出后，才会调用 mergeMap。是否有一个 RxJS 运算符可以让我在第一个 post() 调用发出之前开始轮询？

Answer 1

尝试：

createConversion(request): Observable<any> {
    const post$ = this.http.post('/endpoint', request).pipe(startWith(null)); 
    // force fake emission
    const get$ = this.http.get('/second-endpoint');
    const polling$ = timer(0,5000).pipe(mergeMap(_=> get$), takeUntil(this.converted$));

    return post$.pipe(mergeMap(_=> polling$));
}