3

我有以下ngrx效果。在“地图”里面我有一个条件。如何在不继续 mergeMap 的情况下立即停止效果。

@Effect()
myEffect$: Observable < Action > = this.actions$.pipe(
  ofType('INIT_ACADEMY_DOMAIN'),
  map((action: any) => {
    const url = 'http://www.academy.xyzq';
    if (1 === 1) {
      // Make this effect stop immediately and do nothing more
    }
    action.url = url;
    return action;
  }),
  mergeMap((action: any) =>
    this.http.get(action.url).pipe(
      switchMap((data: any) => {
        return [{
          type: 'INIT_ACADEMY',
          payload: {
            academy: data.academy
          }
        }];
      })
    )),
  catchError(() => of ({
    type: 'INIT_IT_FAILED'
  }))
);

4

2 回答 2

2

您应该考虑使用该filter函数根据您的条件过滤掉操作：

@Effect()
myEffect$: Observable < Action > = this.actions$.pipe(
  ofType('INIT_ACADEMY_DOMAIN'),
  filter((x) => 1 === 1),
  mergeMap((action: any) =>
    this.http.get(action.url).pipe(
      switchMap((data: any) => {
        return [{
          type: 'INIT_ACADEMY',
          payload: {
            academy: data.academy
          }
        }];
      })
    )),
  catchError(() => of ({
    type: 'INIT_IT_FAILED'
  }))
);

或者，如果您的条件为真，您可以只调度一个新动作，并创建一个更简单的效果来执行mergeMap函数内部的部分。

你应该尽量让你的效果尽可能简单。如果你的效果做了很多逻辑/条件检查，很难找到一个合适的名字来捕捉效果的真正作用。

于 2018-08-21T08:42:21.457 回答
1 
You can try like this.

@Effect()
myEffect$: Observable < Action > = this.actions$.pipe(
  ofType('INIT_ACADEMY_DOMAIN'),
  map((action: any) => {
    const url = 'http://www.academy.xyzq';
    if (1 === 1) {
      // Make this effect stop immediately and do nothing more
      return null;
    }
    action.url = url;
    return action;
  }),
  mergeMap((action: any) =>
    if(action){
    return this.http.get(action.url).pipe(
      switchMap((data: any) => {
        return [{
          type: 'INIT_ACADEMY',
          payload: {
            academy: data.academy
          }
        }];
      })
      } else{
        return null;
      }
    )),
  catchError(() => of ({
    type: 'INIT_IT_FAILED'
  }))
);
于 2018-08-03T10:43:53.493 回答