Как реализовать несколько вложенных и взаимозависимых подписок с операторами RxJS? - PullRequest
Новая
       21

Как реализовать несколько вложенных и взаимозависимых подписок с операторами RxJS?

0 голосов
/ 15 апреля 2019

У меня есть вложенная подписка, от которой я хотел бы избавиться, используя подходящий оператор RxJS .Я уже попробовал concatMap и mergeMap , с которыми, к сожалению, не смог решить свою проблему.

У меня есть 3 подписки, которые зависят друг от друга и вызывают новую наблюдаемую вцикл forEach для каждого значения текущего цикла.Чтобы проиллюстрировать это более подробно, вот мой пример кода: 

this.subscriptionOne = this.serviceOne.getStreets().subscribe((streets) => {
  streets.forEach((street) => {
    this.subscriptionTwo = this.serviceTwo.getMetaData(street.id).subscribe((metaDatas) => {
      metaDatas.forEach((md) => {
        // do some stuff and then trigger another observable..
        this.subscriptionThree = this.serviceTwo.getStuff(md.id, md.type, md.name).subscribe((stuff) => {
          // do some other stuff
        });
      });
    });
  });
});

Как я могу избавиться от этого вложения с RxJs?

1 Ответ

5 голосов
/ 15 апреля 2019 
let sub = this.serviceOne
  .getStreets()
  .pipe(
    mergeMap(streets => {
      return from(streets);
    }),
    mergeMap(street => {
      return this.serviceTwo.getMetaData(street.id);
    }),
    mergeMap(metaDatas => {
      return from(metaDatas);
    }),
    mergeMap(md => {
      return this.serviceTwo.getStuff(md.id, md.type, md.name);
    }),
    map(stuff => {
      // do your stuff
    })
  )
  .subscribe();

metaDatas доступно в двух последних операторах: 

let sub = this.serviceOne
  .getStreets()
  .pipe(
    mergeMap(streets => {
      return from(streets);
    }),
    mergeMap(street => {
      return this.serviceTwo.getMetaData(street.id);
    }),
    mergeMap(metaDatas => {
      return from(metaDatas).pipe(
        mergeMap(md => {
          return this.serviceTwo.getStuff(md.id, md.type, md.name);
        }),
        map(stuff => {
          // do your stuff
        })
      );
    })
  )
  .subscribe();
...