1

在我的 Angular 8 应用程序中，我调用 Api 服务，然后将数据写入 Akita Entity Store 以用于后续请求。我通过使用 mergeMap 以同步方式发送请求来做到这一点。

我有一些额外的请求，我希望使用带有此函数的 forkJoin 以并发方式执行，但是，我发现 akita selectAll 函数的以下问题不会触发 onCompleted 函数/事件。它返回数据但 onCompleted 永远不会触发。使 Observable 处于不完整状态。

如果我删除对秋田实体商店的调用。我可以看到函数完成的对 getTeams Observable 的 Api 调用。我向秋田实体商店调用添加了调试代码，并看到 onCompleted 永远不会触发。我不知道为什么，但也许我做错了什么。

功能：

   getTeams(): Observable<Team[]> {
     return this.teamApiService.getTeams().pipe(
      mergeMap((teams) => {
        this.teamStore.set(teams);
        return this.teamQuery.selectAll({ sortBy: 'name' });
      })
     );
   }

调用函数：


   this.teamStateService.getTeams().subscribe(
      data => console.log('GOT getTeams:', data),
      err => console.log('Error:', err),
      () => console.log('getTeams: Completed')
    );

我应该看到以下结果：

GOT getTeams: .... 
getTeams: Completed

但是，我只是得到

GOT getTeams: ....
4

1 回答 1

3

您可以强制它完成。您可以添加take(1)：

return this.teamQuery.selectAll({ sortBy: 'name' }).pipe(take(1));

于 2019-06-28T13:28:52.597 回答