RxJs 6 - Сделайте 2 HTTP-вызова и дождитесь всех ответов

@Effect()    
initDomain$: Observable<Action> = this.actions$.pipe(
  ofType('INIT_DOMAIN'),
  mergeMap((action: any) =>
     this.http.get('https://demo.api/url1.php').pipe(
        switchMap((data) => [
           {type: 'INIT_IT', payload: data}
        ]),
        catchError(() => of({type: 'INIT_IT_FAILED'}))
     )
  )
);

У меня есть угловой эффект (ngrx), который делает 1 запрос перед продолжением. Как я могу сделать 2 запроса и дождаться обоих ответов, прежде чем продолжить? Я знаю, что forkJoin () - это ответ, но меня немного смущает синтаксис


rxjs rxjs6 fork-join ngrx ngrx-effects
person Michalis    schedule 19.07.2018    source источник
comment
learnrxjs.io/operators/combination/forkjoin.html   -  person JB Nizet    schedule 19.07.2018
comment
gist.github.com/peterbsmith2/ce94c0a5ddceb99bab24a761731d1f   -  person Envil    schedule 19.07.2018

Ответы (1)


arrow_upward
1
arrow_downward 

forkJoin(
 this.http.get('myUrl'),
 this.http.get('myOtherUrl')
)

ИЛИ, если у вас есть набор наблюдаемых в массиве, вы также можете написать

const myArrayOfObservables = [
  this.http.get('myUrl'),
  this.http.get('myOtherUrl')
];

forkJoin(
  myArrayOfObservables
)

Это потому, что "forkJoin" использует оператор "spread" (... args) для своих параметров.

person JanRecker    schedule 19.07.2018
comment
Обратите внимание, что все obs будут считаться неудачными, если одно из них не удалось при использовании forkJoin, тогда как некоторые вызовы могли быть успешными. - person maxime1992; 19.07.2018