如何使用 rxjs Observable 更新 Angular Post 请求中的 HttpParams 中的值

Question

我在 Angular13 中有一个轮询服务，它使用 rxjs 间隔从外部服务器拉取数据。我能够在指定的时间间隔内正常获取数据。问题是我无法在下次调用之前用一组新数据更新 httpParams。参数包含一组用作 SQL 约束的 ID。

  getAllCurrencies(id, code): Observable<any> {
  this.bookingCode = code;
  this.bookingId = id;  
  let url = 'someurl';
  let headers = new HttpHeaders({'Content-Type': 'application/x-www-form-urlencoded'});
  let body = new HttpParams()
  .set('booking_code', this.bookingCode)
  .set('booking_id', this.bookingId)
  .set('token', this.token); 
  return this.allCurrencies$ = interval(5000).pipe(
  mergeMap(() =>
    this.http.post<any>(this.GLOBAL_URL + url, body, { headers: headers }).pipe(
      map((res) => {
         let result:any = [];
        if(res.data.length > 0){   
          this.testingOne();         
            this.bookingId = res.data[0].id;
            result = res.data;
        }
        return result;
      }))),retry(),share(),takeUntil(this.stopPolling)
  );
 }

我想在返回新值时更新 .set('booking_id', this.bookingId) 中 this.bookingId 的值，然后继续调用。

Answer 1

试试下面的方法，它应该可以工作

map((res) => {
  let result:any = [];
  
  if(res.data.length > 0){   
    this.testingOne();         
    this.bookingId = res.data[0].id;

    body = body.set('booking_id', this.bookingId);
    result = res.data;
  }
  return result;
})

如何使用 rxjs Observable 更新 Angular Post 请求中的 HttpParams 中的值

How To Update values in HttpParams in Angular Post Request with rxjs Observable

rxjs

angular

rxjs-pipeable-operators