Как вызвать функцию в debounceTime

Question

У меня есть две разные тематические подписки на разные события, которые вызывают одну и ту же функцию.

subject1.subscribe(
_ => callFunction();
);

subject2.subscribe(
_ => callFunction();
);

Мне нужно, чтобы callFunction () не вызывался чаще, чем раз в секунду, как я могу сделать это сrxjs

Answer 1

Вы должны объединить свои наблюдаемые. Если они закончены, используйте forkJoin, иначе combineLatest:

combineLatest(s1, s2).pipe(debounceTime(1000)).subscribe(([r1, r2]) => ...);