Объединить наблюдаемое с несколькими наблюдаемыми - PullRequest
Новая
       9

Объединить наблюдаемое с несколькими наблюдаемыми

0 голосов
/ 03 марта 2020

Здесь я хочу объединить значения из наблюдаемых. Этот код работает, но размещение подписок таким способом не очень хорошо. Я ищу лучшие решения. Заранее спасибо. 

someObservable().subscribe(
      data => {                      // array of elements
        data.forEach(
          element => {
            anotherObservable(element.id)
              .subscribe(
                anotherData => doSomething(data, anotherData); // both data needed
              );
          }
        );
      }
    );

Ответы [ 2 ]

2 голосов
/ 03 марта 2020

Вы можете использовать mergeMap для него

Как это: 

return this.someObservable().pipe(
  mergeMap(element=> this.anotherObservable(element.id).pipe(
    map(anotherData => {
      return {
        res1: element ,
        res2: anotherData 
      }
    })
  ))
)
1 голос
/ 03 марта 2020

Вы можете использовать слияние для этого

Нажмите здесь для Официального Do c

Например: - 

// RxJS v6+
import { mapTo } from 'rxjs/operators';
import { interval, merge } from 'rxjs';

//emit every 2.5 seconds
const first = interval(2500);
//emit every 2 seconds
const second = interval(2000);
//emit every 1.5 seconds
const third = interval(1500);
//emit every 1 second
const fourth = interval(1000);

//emit outputs from one observable
const example = merge(
  first.pipe(mapTo('FIRST!')),
  second.pipe(mapTo('SECOND!')),
  third.pipe(mapTo('THIRD')),
  fourth.pipe(mapTo('FOURTH'))
);
//output: "FOURTH", "THIRD", "SECOND!", "FOURTH", "FIRST!", "THIRD", "FOURTH"
const subscribe = example.subscribe(val => console.log(val));
...