Как правильно обрабатывать ошибки в этом эффекте? - PullRequest
Новая
       7

Как правильно обрабатывать ошибки в этом эффекте?

0 голосов
/ 13 ноября 2018

Я написал Эффект ниже, чтобы сделать запросы для каждого элемента в массиве, и когда один из них завершается неудачей, ошибка не обрабатывается, и наблюдаемый поток завершает результирующие действия, больше не вызывая эффекты. 

Effect:

@Effect() myEffect$ = this.actions$.pipe(
     ofType<myAction>(myActionTypes.myAction),
     mergeMapTo(this.store.select(getAnArray)),
     exhaustMap((request: any[]) => {
        return zip(...request.map(item => {
           return this.myService.myFunction(item).pipe(
              map(response => {
                 return this.store.dispatch(new MyActionSuccess(response))
              }),
              catchError(error => {
                 return Observable.of(new MyActionFailure(error));
              })
           )
        }))
     })

Как мне исправить ошибку в этом случае?

...