2

我正在我的解析器中加载一名员工。该员工返回城镇 ID 列表。我想在同一个解析器中加载这个城镇的 id 列表中的所有城镇。但我不想返回城镇列表,我想返回员工。加载的城镇将被添加到缓存服务中以供以后使用。这是我的代码

resolve(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<any> {

    return this.employeeService.getEmployee(route.params['id'])
        .pipe(
            map(employee => {
                const townsObservables = [];
                employee['town_list'].forEach((townId) => {
                    townsObservables.push(this.townService.getTown(townId));
                });
                return forkJoin(townsObservables).pipe(
                    map(town => {
                        this.townCache.addTown(town);
                        return employee;
                    })
                );
            })
        );
}

问题:永远不会执行 forkJoin,并且我的组件中的路由快照数据返回 Observalbe 而不是员工。

route.snapshot.data['employee'] // returns Observable {_isScalar: false, source: Observable, operator: MapOperator}

在没有管道中的所有代码的情况下,employeeService 运行良好,此代码按预期工作(我可以在我的快照数据中获取我的员工):

resolve(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<any> {
    return this.employeeService.getEmployee(route.params['id']);
}

问题:加载相关数据而不在解析器中返回它们的正确方法是什么?我正要尝试使用两个单独的解析器,但无法链接解析器(无法告诉解析器 B 使用来自解析器 A 的数据)。

我正在使用带有 RXJS ^6.2.1 的 Angular 6。

4

1 回答 1

1

mergeMap如果你想订阅,你应该使用forkJoin

return this.employeeService.getEmployee(route.params['id'])
    .pipe(
        mergeMap(employee => { // <-- HERE changed to mergeMap
            const townsObservables = [];
            employee['town_list'].forEach((townId) => {
                townsObservables.push(this.townService.getTown(townId));
            });
            return forkJoin(townsObservables).pipe(
                map(town => {
                    this.townCache.addTown(town);
                    return employee;
                })
            );
        })
    );

map和之间的主要区别mergeMap

map(val => of(val))-> 结果Observable<Observable<val>>

mergeMap(val => of(val))-> 结果Observable<val>

它相当于.pipe(map(val => of(val)), mergeAll())

于 2018-08-28T16:20:30.177 回答