Блог

У меня есть массив наблюдаемых a$, b$, c$, d$ объектов. Я хочу, чтобы они выполнялись последовательно. Например, если a$ завершается, то b$ . Если b$ завершается, то $c …

Я знаю forkJoin([a$, b$, c$, d$]) , за исключением того, что он будет делать это параллельно. Есть ли соответствующий оператор? Или я могу указать forkJoin запускать последовательно?

Вы можете использовать concat для их последовательного запуска:

 concat(a$, b$, c$).subscribe(console.log);
  

Если вы также хотите пропустить какие-либо промежуточные выбросы из исходных наблюдаемых объектов в результирующем наблюдателе, вы можете использовать что-то вроде

 concat(...[a$, b$, c$].map(source$ => source$.pipe(last())));
  

… или, если вы хотите собрать только последнее излучение каждого наблюдаемого источника в одно подобное излучение forkJoin , вы присоединяете toArray к нему:

 concat(...[a$, b$, c$].map(source$ => source$.pipe(last()))).pipe(
  toArray(),
);
  

Конечно, вы могли бы извлечь это в свой собственный оператор сейчас, если хотите:

 const concatLast = <T>(...sources: Observable<T>) => concat(
  ...sources.map(source$ => source$.pipe(last()))
).pipe(
  toArray(),
);
  

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

На веб-сайте rxjs есть полезный инструмент, называемый деревом решений оператора, который поможет вам определить подходящий оператор, например, в этом случае

• У меня есть несколько наблюдаемых объектов для объединения в один наблюдаемый объект, и
• Я хочу подписаться на каждый по порядку