0

可能有不同的方法来解决它（比如创建另一个选择器，特别是针对错误）

    export const getMSFState = createFeatureSelector<STState>('st');
    export const selectCreatedSensor = createSelector(
        getMSFState,
        selectAllSensors,
        (state: STState, sensorArray: SeasonTotals[], props: { blockId: number}) => {
            const isSuccessCreate = state.action === fromST.ST_ADD_ELEMENT && !state.loading && !state.error;
            const isAnErrorCreate = state.action === fromST.ST_ADD_ELEMENT && !state.loading && state.error;
            if (isAnErrorCreate) {
                return throwError('Error X');
            }
            const blockSensors = [...sensorArray].filter(s => s.blockId = props.blockId);
            return isSuccessCreate ? blockSensors.pop() : null;
        }
    );

我想捕捉第二个订阅参数（错误之一），但我不知道是否可以在 NgRx 选择器中发出它

    this.store.pipe(
        select(STSelectors.selectCreatedSensor, { blockId: this.id })
    ).subscribe((data) =>  {
        console.log('success creation', data);
    }, (error) => {
        // I can't catch this, instead I catch it in the first subscribe parameter (in the success one)
        // And the value emited is an Observable object
        console.log('something went wrong', error); 
    })
4

2 回答 2

1

选择器是纯函数，我发现在选择器（和减速器）中抛出错误是一种不好的做法。您应该返回一个值（null, undefined，空对象，...）。

于 2019-11-21T20:58:29.843 回答
0

选择器总是返回关于当前非 astate的部分信息。storestream

throwError向流返回错误observable，因此您无法返回实际状态。

... basically what will happen is you will get something like Observable<Observable<Error>>when the throwErrorfunction in the selector returns, therefore this will not work.

...

第一：你用错了商店，你应该：

  • 发送getData事件
  • 如果出现错误：一个getDataError事件
  • getDataSuccess如果事件成功

我的方法是创建一个独占loadingSelector loadedSelector并将errorSelector数据加载包装在 a serviceorfacade或任何您想要调用的名称中，并在那里进行错误处理，以便您可以在组件中正确订阅：

getData(): Observable<MyData> {
   return this.store.select(selector.loaded)
     .pipe(
       switchMap(loaded => {
          if (loaded) {
             return this.store.select(selector.myData);  // if data already loaded return it
          }
          this.store.dispatch(loadingAction);  // dispatch loading event
          return this.store.select(selector.loading) // select the loading state
       })
       filter(loading => !loading), // wait until loading changes to false
       switchMapTo(this.store.select(selector.error)), // get current error state
       switchMap(error => { 
          if (error) {
            return throwError(error); // throw error if exits
          }
          return this.store.select(selector.myData); // otherwise return data
       })
     }
}
于 2019-11-21T19:40:48.130 回答