Добавление условного действия pipe () внутри merge ()

Question

Case

Использование merge() для объединения 3 источников данных на странице:

merge(this.sort.sortChange, this.paginator.page, this.searchQuery$)
      .pipe(
        distinctUntilChanged(),
        switchMap(() => {

Задача

sort и paginator are instant source (пользователь нажимает на элемент управления и мгновенно меняет значение. Пока searchQuery генерируется полем ввода текста.

Я хотел бы добавить debounceTime(500), но только для searchQuery$ в то время как , включая другие 2 источника .

Как этого добиться с помощью RxJs?

Answer 1

Вы можете добавить операторы в pipe к любому наблюдаемому.

merge(
  this.sort.sortChange, 
  this.paginator.page, 
  this.searchQuery$.pipe(debounceTime(500))
)