Angular 使用 RxJS forkJoin 时传递参数的最佳方式

发布于05月24日

所以，我有一个服务，它有三个我需要执行的功能.

我使用forkJoin是因为我想在收到所有人的回复后采取进一步行动！

getDevices(id: string): Observable<IEquipmentRow[]> {
    const url = `${apiUrl}/${id}`;
    return this.http.get<IGetDevicesResponse>(url)
      .pipe(
        map(res => {
          return res.data;
        })
      );
}

private regions$ = this.getRegions();
private devices$ = this.getDevices();


public equipmentPreparationData$ = forkJoin({
    regions: this.regions$,
    devices: this.devices$
});

实现这一点的最佳方式是什么？可能使用RxJS Subject/BehaviorSubject？

推荐答案

try 使用:

// Change your response type
public equipmentPreparationData$(deviceID: string): Observable<any> {
 return forkJoin({
    regions: this.regions$,
    devices: this.getDevices(deviceID)
});


private getDevices(id: string): Observable<IEquipmentRow[]> {
    const url = `${apiUrl}/${id}`;
    return this.http.get<IGetDevicesResponse>(url)
      .pipe(
        map(res => {
          return res.data;
        })
      );
}

private regions$ = this.getRegions();

通过这种方式，您可以将函数与参数一起使用，并通过getDevices方法传递