RxJS ждут, пока наблюдаемое завершится полностью

Question

Я пытаюсь завершить Observable полностью (то есть вызывается функция Complete) до выполнения следующей Observable. Я пробовал много разных вещей, но самое близкое, что я получил, это:

function() {
  observableA.subscribe(
    (value) => { },
    (err) => { },
    () => {
      createObservableB();
    }
  );
  return observableB; // ????
}

Но мне нужно вернуть результат из createObservableB () из этой функции. Опять же, createObservableB не может быть вызван до тех пор, пока каждое отдельное значение в observableA не будет полностью повторено.

Спасибо за любую помощь!

Answer 1

Более «чистое» решение будет использовать просто concat, потому что оно подписывается на Observables по одному только после завершения предыдущего:

import { concat } from 'rxjs';

concat(observableA, observableB)
  .subscribe(...)

Если вы хотите игнорировать все значения, поступающие из observableA, вы можете использовать ignoreElements() при передаче его в concat (observableA.pipe(ignoreElements())).

Answer 2

можно попробовать last, оператор

obsA.pipe(last(),mergeMap(()=>obsB)).subscribe()