auditTime
function stable operator
Игнорирует значения источника в течение duration миллисекунд, затем излучает последнее значение из исходного Observable, затем повторяет этот процесс.
auditTime<T>(duration: number, scheduler: SchedulerLike = asyncScheduler): MonoTypeOperatorFunction<T>
Параметры
duration | number | Время ожидания перед излучением последнего значения источника, измеряемое в миллисекундах или единице времени, определяемой внутри с помощью необязательного |
scheduler | SchedulerLike | Необязательно. По умолчанию |
Возвращает
MonoTypeOperatorFunction<T>: Функция, которая возвращает Observable, выполняющий ограничение скорости излучения из исходного Observable.
Описание
При получении значения источника, он игнорирует его и последующие значения в течение duration миллисекунд, а затем излучает последнее значение из источника.
auditTime аналогично throttleTime, но излучает последнее значение из заглушенного временного интервала, а не первое. auditTime излучает последнее значение из исходного Observable в выходной Observable, как только его внутренний таймер отключается, и игнорирует значения источника, пока таймер включен. Изначально таймер отключен. Как только придёт первое значение источника, таймер включается. По истечении duration миллисекунд (или единицы времени, определяемой внутри с помощью необязательного scheduler) таймер отключается, затем последнее значение источника излучается в выходной Observable, и этот процесс повторяется для следующего значения источника. Необязательно принимает SchedulerLike для управления таймерами.
Пример
Излучение нажатий на кнопки со скоростью не более одного нажатия в секунду
import { fromEvent, auditTime } from 'rxjs';
const clicks = fromEvent(document, 'click');
const result = clicks.pipe(auditTime(1000));
result.subscribe(x => console.log(x)); См. также
© 2015–2022 Google, Inc., Netflix, Inc., Microsoft Corp. and contributors.
Code licensed under an Apache-2.0 License. Documentation licensed under CC BY 4.0.
https://rxjs.dev/api/operators/auditTime