redux-observable wont be execute after catchError

Question

I am using redux-observable in my angular project. I have an updateNode function in my epics with catchError handling. I dispatch action DB_UPDATE_NODE many times and everything work well. However the time action execute catchError when I dispatch that action again, updateNode function wont be called any more.

public updateNode(action$: Observable<IScenarioNodesAction>, store: Store<IAppState>) {
  return action$.pipe(
    ofType(ScenarioNodeActionType.DB_UPDATE_NODE),
    flatMap((action) => {
     return  this._scenarioNodeService.update(action.payload.botId);
    }),
    flatMap(data => [
      this._scenarioNodeAction.updateNode(data),
    ]),
    catchError((error) => { 
      return Observable.of(this._commonAction.showError(error));
    })
  );
}

Answer 1

You have to catch the error on the service's stream.

flatMap((action) => {
  return this._scenarioNodeService.update(action.payload.botId)
             .pipe(catchError(...)) ;
})

See the docs for more information.

Here we placed the catchError() inside our mergeMap(), but after our AJAX call; this is important because if we let the error reach the action$.pipe(), it will terminate it and no longer listen for new actions.