RxJS forkJoin 未完成

Question

当我订阅 getAllSubModules 时，forkJoin 无误地执行了所有这些可观察对象，但没有完成。我知道 forkJoin 仅在其所有可观察对象完成后才完成，但作为证据，我在控制台中看到“-----” 3 次，确认一切成功，因此其所有可观察对象都已完成。

 getSubmodules(id): Observable<any> {
    return this.authService.getToken()
      .flatMap((token) => this.http.get(`${this.URL}/ROS/applications/modules/${id}/subModules?token=${token}`))
      .map((res: any) => res.data.map((subModule) => this.mapSubModules(subModule)));
  }
  getAllSubmodules(): Observable<any> {
    const tasks = [];
    this.modules.forEach((module: AppModule) => {
      const obs = this.getSubmodules(module.id).map((subModules) => {
        this.allSubModules[module.id] = subModules;
        console.log('--------------------');
      });
      tasks.push(obs);
    });
    return Observable.forkJoin(...tasks).retry(2);
  }
  mapSubModules(moduleData) {
    if (moduleData.id) {
      const subModule = <SubModule> {
        id: moduleData.id,
        parentId: moduleData.parentId,
        typeId: moduleData.typeId,
        name: moduleData.name.az,
        active: true
      };
      return subModule;
    }
  }

使用forkJoin时不执行此代码:

 this.universityService.getAllSubmodules().subscribe(() => {             
        // --- Below is not executed!--
        console.log('subModules in Report Co');
        console.log(this.universityService.allSubModules);
        this.checkUrl();
        this.showChild = true;
      }, (er) => console.log(er));

但是当我使用 combineLatest 而不是 forkJoin 时，它会按预期工作。那到底是什么问题呢？希望有人指点一下。

Answer 1

您的期望不正确。 console.log('--------------------') 发出 3 次仅意味着您收到了 3 个 onNext 事件。 forkJoin 等待所有可观察对象完成。

尝试使用 .do(next=>{},err=>{},complete => console.log('completed')) 查看各个流或使用 .take(1) and/or .timeout(1000).[=17= 明确定义流应何时完成时会发生什么]

发出一个值后authService..getToken()是否完成？

RxJS forkJoin 未完成

RxJS forkJoin does not complete

rxjs

rxjs5

angular