在NgRX createEffect调用中模拟catchError

import { Injectable } from '@angular/core';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import { catchError, map, mergeMap } from 'rxjs/operators';
import { of } from 'rxjs';

@Injectable()
export class MyEffects {
  myEffect$ = createEffect(() =>
    this.actions$.pipe(
      ofType('MY_ACTION'),
      mergeMap(() =>
        this.myService.getData().pipe(
          map(data => ({ type: 'SUCCESS_ACTION', payload: data })),
          catchError(error => {
            // 错误处理逻辑
            console.error('An error occurred:', error);
            return of({ type: 'ERROR_ACTION', payload: error });
          })
        )
      )
    )
  );

  constructor(private actions$: Actions, private myService: MyService) {}
}