Цепные операторы rxjs

Question

У меня есть функция с именем fetch, которая реализована следующим образом:

fetch(): Observable<Option> {
    return this.clientNotebookService.getClientNotebook()
      .pipe(
        map(
          clientNotebook => {
            this.person = _.find(clientNotebook.persons, i => i.isn === this.isn);
            return {
              value: this.person.address['TownIsn'],
              name: this.person.address['TownName']
            };
          }
        )
      );
}

, где person имеет тип RelatedPerson и isn, если имеет тип string.Проблема с этой функцией в том, что она ничего не знает о isn, то есть, isn должен быть ей каким-то образом предоставлен.

Это значение можно извлечь следующим образом:

this.activatedRoute.params.subscribe(
    params => this.isn = params['id']
)

И я хотел бы сделать это в методе fetch, комбинируя операторы rxjs.

Answer 1

Вы можете связать их, как показано ниже, просто извлеките 'id' и передайте его для извлечения

const isn=this.activatedRoute.params.pipe(pluck('id'))
isn.pipe(mergeMap(isn=>fetch(isn)))

Затем добавьте параметр к вашему извлечению, тогда он будет доступен внутри функции

fetch(isn){ .....

Answer 2

Вы можете использовать объединение, которое выдает массив последнего значения из обоих потоков каждый раз, когда либо выдает значение

combineLatest(
  this.activatedRoute.params.pipe(map(params => params['id'])),
  this.clientNotebookService.getClientNotebook()
).pipe(map(([isn, clientNotebook]) => {
  this.person = clientNotebook.persons.find(p => p.isn === isn); // No need for _
  return {
    value: this.person.address['TownIsn'],
    name: this.person.address['TownName']
  };
}));