У меня есть две разные тематические подписки для разных событий, которые вызывают одну и ту же функцию.
subject1.subscribe(
_ => callFunction();
);
subject2.subscribe(
_ => callFunction();
);
мне нужно, чтобы callFunction() не вызывалась чаще, чем раз в секунду, как я могу сделать это с помощью rxjs?





Вы должны объединить свои наблюдаемые. Если они закончились, используйте forkJoin, иначе combineLatest :
combineLatest(s1, s2).pipe(debounceTime(1000)).subscribe(([r1, r2]) => ...);
Возможный дубликат Угловой и устранение дребезга