source1$.pipe(
  catchError((error, source) => of(`Error ${error}`))
)
source1$.pipe(
  catchError((error, source) => {
    callFlashMessageError(error),
    return source.pipe(
      switchMap(() => callInitialState())
    )
  })
)