在catchError里面的Ngrx mergeMap加入更多动作让我出错

问题描述 投票:-1回答:1

我想在catchError块中调度两个动作,但是我遇到了这个错误

类型'(error:{})=> void'的参数不能分配给类型'(value:{},index:number)=> ObservableInput <{}>'的参数。类型'void'不能分配给'ObservableInput <{}>'类型

import { Injectable, Inject } from '@angular/core';
import { Actions, Effect } from '@ngrx/effects';
import { Router } from '@angular/router';

import { catchError, map, mergeMap, switchMap } from 'rxjs/operators';
import { of } from 'rxjs/observable/of';

import {
  AuthenticationAccount
} from '../../models/account.model';

import * as fromActions from '../actions';

import { ACCOUNT_SERVICE } from '../../tokens';

@Injectable()
export class AccountEffects {
  @Effect()
  account$ = this.actions$.ofType(fromActions.ACCOUNT)
    .pipe(
    switchMap(() => {
      return this.accountService.account()
        .pipe(
        map((account: AuthenticationAccount) => {
          return { type: fromActions.ACCOUNT_SUCCESS, payload: account };
        }),
        catchError((error) => {
          this.router.navigateByUrl('/home');
          return mergeMap((error) => {
            [{ type: fromActions.ACCOUNT_FAIL, payload: error },
            { type: fromActions.LOGIN_RESET}]
          })
        })
        )
    })
    );
  constructor(
    private actions$: Actions,
    private router: Router,
    @Inject(ACCOUNT_SERVICE) private accountService
  ) { }
}

你能帮我吗?

angular rxjs ngrx ngrx-effects
1个回答
3
投票

catchError部分是错误的,你使用mergeMap作为静态方法,但在pipe范围之外,这是不可能的。

修改如下:

import { from } from 'rxjs/observable/from':

catchError((error) => {
          this.router.navigateByUrl('/home');
          const actions = [{ type: fromActions.ACCOUNT_FAIL, payload: error }, { type: fromActions.LOGIN_RESET}];
          return from(actions);
        })

BTW:

  • 为什么要使用令牌注入服务?
  • 你为什么不使用动作创作者?您可以使用类或方法来生成新对象,而不是创建新对象。
© www.soinside.com 2019 - 2024. All rights reserved.