例題

AActionを拾うAEffect内で

「BAction」
「ServiceのcFuncを呼び出し及びその結果=CAction+エラーハンドラErrorAction」
「DAction」

を順番に呼び出したい。

解

// import等は省略
// ActionTypes等は別途定義済とする

@Injectable()
export class MyEffect {
  constructor(
    private readonly actions$: Actions,
    private readonly service: Service,
  ) {}

  @Effect()
  aEffect$: Observable<Action> = this.actions$.pipe(
    ofType<AAction>(ActionTypes.AAction),
    switchMap(() =>
      concat(
        of(new BAction({})),
        this.service.cFunc().pipe(
          map(({ result }) => new CAction({ result })),
          catchError(error => of(new ErrorAction({ error }))),
        ),
        of(new DAction({})),
      ),
    ),
  );
}

switchMapからのconcatで順番保証しつつ、ofやらpipeからのmapおよびcatchErrorで複数回Actionを呼び出しています。

スマートではないけど、動いていてはいる。

順番にこだわらない場合はmergeでもいけると思う。