Как укомплектовать комбайнПоследний?

Question

Я использую combineLatest для получения последних значений из каждой наблюдаемой:

combineLatest$ = combineLatest(_block$, _field$);
    combineLatest$.subscribe(() => {
      console.log("Completed...");
    });

Затем у меня есть другая наблюдаемая, которая работает до тех пор, пока forkJoin$ не отправит данные:

of(true).pipe(delay(1000), takeUntil(combineLatest$)).subscribe(() => console.log());

Как полный combineLatest$? А мне отписаться от of() или он будет уничтожен автоматически?

Answer 1

Нет. takeUntil запустит слезную логику c для вас. Кажется, вы путаете семантику forkJoin с combileLatest, они совершенно разные. В вашем конкретном случае forkJoin$ не имеет истинной семантики forkJoin ; Я полагаю, вам нужно заполнить оба поля _block$ и _field$, чтобы выполнить combineLatest.

Answer 2

Просто передайте endWith как _block $, так и _field $, когда они получат удовлетворительное значение, что завершит ваш поток ОбъединитьПоследний $.

Редактировать: Просто завершить sh поток без излучения чего-либо, вы используете const EMPTY .pipe(switchMap(() => EMPTY))