Похоже, вы могли бы использовать switchMap
для отмены любых ожидающих запросов (запросы, которые занимают более 5 с) или exhaustMap
для ожидания завершения активного запроса, игнорируя при этом любые последующие выбросы из * 1005.* (это зависит от того, чего вы хотите достичь).
timer(0, 5000)
.pipe(
exhaustMap(() => this.httpService.getEvents()),
take(1),
repeat(),
)
.subscribe(console.log)