时间戳

首页 > 解决方案 > NgRx：获取“您在预期流的位置提供了‘未定义’。” 调用完整动作时生效

angular - NgRx：获取“您在预期流的位置提供了‘未定义’。” 调用完整动作时生效

问题描述

我正在尝试进行 API 调用并将现有数据与现有数据合并（合并在 addMissingData 中完成）。当我尝试调用时出现错误：

未捕获的类型错误：您在预期流的位置提供了“未定义”。您可以提供 Observable、Promise、Array 或 Iterable。

在 subscribeTo (subscribeTo.js:27) 在 subscribeToResult (subscribeToResult.js:11) 在 MergeMapSubscriber._innerSub (mergeMap.js:59) 在 MergeMapSubscriber._tryNext (mergeMap.js:53) 在 MergeMapSubscriber._next (mergeMap.js:36 ) 在 MergeMapSubscriber.next (Subscriber.js:49) 在 MapSubscriber._next (map.js:35) 在 MapSubscriber.next (Subscriber.js:49) 在 CatchSubscriber._next (Subscriber.js:72) 在 CatchSubscriber.next (订阅者.js:49)

 GetStepWiseMasterData$ = createEffect(() => this.actions$.pipe(
            ofType(MasterDataAction.getCustomerMasterData),
            switchMap((action) => {
                return this.dataService.GetDataAsync(action.stepEnum).pipe(
                    map((response) => {
                        return {
                            isSuccess: response.isSuccess,
                            newData: response.data,
                            data: action.data,
                        };
                    }),
                    mergeMap((response) => {
                        if (response.isSuccess) {
                            this.addMissingData(response.newData, action.data).then(result => {
                                return [DataAction.getCustomerDataComplete({ customerData: result })];
                            });
                        } else {
                            return [DataAction.getCustomerDataFailed({ customerData: {} })];
                        }
                    }),
                    catchError(() => EMPTY)
                );
            })
        ));

   async addMissingData(newMasterData: BusinessPartnerMasterDataVM, existingMasterData: BusinessPartnerMasterDataVM = {}): Promise<any> {
        const omitNullValues = masterDataObj => new Promise((resolve) => {
            // filter with property name and delete all properties that are null
            Object.keys(masterDataObj).filter(propertyName => masterDataObj[propertyName] === null).forEach(propertyName => delete(masterDataObj[propertyName]));
            resolve(masterDataObj);
        });
        const masterNew = await omitNullValues(newMasterData);
        const masterOld = await omitNullValues(existingMasterData);
        const ret = Object.assign({}, masterNew, masterOld);
        return ret;
    }

标签： angulartypescriptrxjsngrxngrx-store

解决方案

好像你的问题发生在这个区域，

mergeMap((response) => {
    if (response.isSuccess) {
        this.addMissingData(response.newData, action.data).then(result => {
            return [DataAction.getCustomerDataComplete({ customerData: result })];
        });
    } else {
        return [DataAction.getCustomerDataFailed({ customerData: {} })];
    }
})

在这里，if (response.isSuccess)条件分支中没有任何返回。据我了解，您想调用两个 API，它们是

  1. 第一次通话getCustomerMasterData
  2. 然后使用 的结果getCustomerMasterData，您想调用addMissingData

我的建议是创建另一个函数来调用上面的 api，然后使用管道。

GetStepWiseMasterData$ = createEffect(() => this.actions$.pipe(
    ofType(MasterDataAction.getCustomerMasterData),
    switchMap((action) => {
        return from(this.combinedFunction(action)).pipe(
            map((result) => {
                return { masterData: result };
            }),
            switchMap((result) => {
                return [MasterDataAction.getCustomerDataComplete(result)];
            })
        );
    })
));

async combinedFunction(action) {
    const response = await this.dataService.GetDataAsync(action.stepEnum).toPromise();
    if (!response.isSuccess) {
        return {};
    }
    return await this.addMissingData(response.newData, action.data);
}

from需要将 Promise 转换为可以从 导入的 Observable rxjs，或者您可以修改combinedFunction以返回 Observable。

希望这有帮助:)

推荐阅读