Перебираем наблюдаемые значения и подписываемся на новые наблюдаемые - PullRequest
Новая
       8

Перебираем наблюдаемые значения и подписываемся на новые наблюдаемые

0 голосов
/ 02 декабря 2018

Скажем, если в Observable есть Array, для каждого значения этого массива необходимо выполнить вызов API (который снова возвращает Observable).Я приведу это к простому примеру.Поскольку мне нужно перебирать первые observables значения, как мне убедиться, что data содержит фактические данные, а не другие наблюдаемые?

Я пробовал switchMap, mergeMap и т. Д.. 

const observables = Observable.of([{ id: 1 }, { id: 2 }]);
const data = Observable.of('data');

observables.pipe(

  // I tried a lot, something like this
  map(values => {
    if(Array.isArray(values)) {
      values.map(value => value.data = data); // data will be an Observable
    }
    return values;
  })

).subscribe(result => {
  console.log(result) // I want: [{ id: 1, data: 'data' }, { ... }]
});

1 Ответ

0 голосов
/ 02 декабря 2018

В зависимости от ваших требований по отправке запросов API вы можете использовать любой из mergeMap, concatMap, forkJoin и т. Д.

Я приведу пример с использованием forkJoin и mergeMap

const observableData: Observable<{id: number, data?: any}[]> = of([{ id: 11 }, { id: 12 }]);
return observableData.pipe(
  mergeMap(values => {
    // first map all the observales to make an array for API calls
    let apiArray = values.map((eachValue) => {
      return this.yourApiService.getData(eachValue.id)
    })
    // now you have to make API calls
    return forkJoin(...apiArray).pipe(
      map(apiData => {
        // now modify your result to contain the data from API
        // apiData will be an array conating results from API calls
        // **note:** forkJoin will return the data in the same sequence teh requests were sent so doing a `forEach` works here
        values.forEach((eachOriginalValue, index) => {
          eachOriginalValue.data = apiData[index].name  // use the key in which you get data from API
        });
        return values
      }),
      catchError((e) => {
          console.log("error", e);
          return of(e)
      })
    )

  })
);

См. Рабочий пример здесь: https://stackblitz.com/edit/forkjoinwithmergemap?file=src%2Fapp%2Fapp.component.ts

...