需要帮助将 rxjs forkjoin 调用转换为异步调用（在 ngrx @Effect 内）

Question

我想重构一组使用 forkJoin 工作的服务调用。我有一组来自ngrx Store的项目，我需要为每个项目进行http调用）。

forkjoin 的问题在于它本质上是一个阻塞操作，所以我需要等待所有调用在它返回之前完成 - 它可能是一个很长的列表。

我希望调用是异步的 - 因此循环每个项目，调用服务并返回结果，以便 UI 更新项目。 （为了使事情复杂一点，这被包裹在一个ngrx @Effect中）

这是我的工作代码：

@Effect()
    loadItemValues$: Observable<Action> = this.actions$
        .ofType(setActions.LOAD_ITEMS_DATA)
        .map(toPayload)
        .switchMap(key => {
            return this.store.select(fromRoot.getItems)
                .flatMap(items => {
                    let observables = new Array();
                    for (let i of items) {
                        observables.push(this.myService.getItemInfo(i, key));
                    }
                    return Observable.forkJoin(observables)
                    .map((res: Grades[]) => {
                        return new setActions.LoadValuesSuccessAction(res); 
                    })
                })
        })

我假设我需要创建一个新的 Observable 并再次使用 flatmap，但要弄清楚如何/什么传递回链以确保为每个项目调用服务并随后调用带有结果的 LoadValuesSuccessAction Reducer .

任何帮助将不胜感激。

Answer 1

变化很小。您需要做的就是替换这个：

return Observable.forkJoin(observables)
.map((res: Grades[]) => {
    return new setActions.LoadValuesSuccessAction(res); 
})

用这个：

return Observable.merge(...observables)
.map((res: Grades) => {
    return new setActions.LoadValuesSuccessAction([res]);
})

不要使用forkJoin，而是使用merge。这将看到单个Grades 发出（一旦它们可用）而不是单个Grades[]。您还需要将收到的 res 包装在一个数组中，因为您的操作创建者似乎接受了 Grades[] 参数。