Как я могу получить, если определенный запрос был выполнен с использованием forkJoin в Angular 5 как часть параллельной обработки запроса? - PullRequest
Новая
       8

Как я могу получить, если определенный запрос был выполнен с использованием forkJoin в Angular 5 как часть параллельной обработки запроса?

0 голосов
/ 06 января 2020

У меня есть требование обрабатывать список запросов параллельно с использованием forkJoin в Angular 5. Я взял ссылку по этой ссылке Rx JS recipes: 'forkJoin' с прогрессом завершения для массовых сетевых запросов в Angular

У меня есть одна проблема здесь. Я не могу точно определить, какой запрос был выполнен, но я могу получить количество запросов, которые были выполнены.

Может кто-нибудь сообщить мне, как узнать, какой именно запрос был выполнен?

Ниже приведен код 

let Rx = window.Rx = window['rxjs'];
let {forkJoin, Subject, merge, of, defer, concat, throwError} = Rx;
let {ajax} = Rx.ajax;
let {map, filter, tap, takeLast, scan, startWith, mergeMap, finalize, ignoreElements} = Rx.operators;
console.clear();

function forkJoinWithProgress(arrayOfObservables) {

   return defer(() => {
   let counter = 0;
   const percent$ = new Subject();

   const modilefiedObservablesList = arrayOfObservables.map(
       (item, index) => item.pipe(
         finalize(() => {
           const percentValue = ++counter * 100 /  arrayOfObservables.length;
           percent$.next(percentValue);
         })
       )
   );

   const finalResult$ = forkJoin(modilefiedObservablesList).pipe(
     tap(() => {
       percent$.next(100);
       percent$.complete();
     }
   ));

   return of([finalResult$, percent$.asObservable()]);
 })

}

const getUserDetails = userIdsList => {

  const arrayOfObservables = userIdsList.map((userId, index) =>{
    //if (index === 1) return throwError({message: 'Vah-vah!'}); // testin with error

    return ajax('https://jsonplaceholder.typicode.com/comments/' + userId)
  }
  )

  return forkJoinWithProgress(arrayOfObservables)
}


const result$ = getUserDetails([1, 2, 15]);

result$.pipe(
  mergeMap(([finalResult, progress]) => merge(
    progress.pipe(
      tap((value) => console.log(`${value} completed`)),
      ignoreElements()
    ),
    finalResult
  ))
).subscribe(values => console.log(values), console.warn);

1 Ответ

3 голосов
/ 06 января 2020

Согласно документации forkJoin, он будет ждать завершения всех из них и поддерживает порядок, в котором вы выстроили запросы, и для наблюдаемых.

forkJoin будет ждать всех передал Observables для завершения, а затем он выпустит массив с последними значениями из соответствующих Observables. Поэтому, если вы передадите n Observables оператору, результирующий массив будет иметь n значений, где first value - это последнее, что испускается первым Observable, второе значение - это последнее, что испускается вторым Observable, и так далее.

Полная информация: Документы и полезная информация Средняя статья

Итак, в вашем примере, вы проводите через них oop userIds будет порядком наблюдаемых, которые вы получите.

...