如何在switchOperator中调用forkJoin？

Question

我已经尝试在switchMap中调用forkJoin：

this.route.params.pipe(
  pluck('cadnum'),
  tap((cadnum) => {
    this.r1.repositoryModel.findallversionbycadnum.model.cadnum = cadnum;
    this.r2.repositoryModel.findallversionbycadnum.model.cadnum = cadnum;
    this.r3.repositoryModel.findallversionbycadnum.model.cadnum = cadnum;
  }),
  switchMap(() => forkJoin(
    egrn.parcels.versions.load(),
    egrn.premisses.versions.load(),
    egrn.rights.versions.load()).pipe(
      tap(([res1, res2, res3]) => {
        egrn.parcels.versions.set(res1);
        egrn.premisses.versions.set(res2);
        egrn.rights.versions.set(res3);
      }),
      catchError((error) => of(error)),
    ),
  ),
)).subscribe((response) => {
  console.log(response);
});

但是不行，怎么在switchMap里面调用forkJoin？

Answer 1

要 forkJoin 发出结果，所有egrn.parcels.versions.load(), egrn.premisses.versions.load(), egrn.rights.versions.load() 都必须是完整的。

您可以尝试将forkJoin 切换为combineLatest 或在第一次发射后使用take(1) 结束流，例如：egrn.parcels.versions.load().pipe(take(1))