sample

Выпускает последнее значение, выпущенное источником Observable, всякий раз, когда другое Observable, notifier, выпускает значение.

sample<T>(notifier: ObservableInput<any>): MonoTypeOperatorFunction<T>

Параметры

notifier

ObservableInput<any>

Используемое Observable для выборки значений из исходного Observable.

Возвращаемое значение

MonoTypeOperatorFunction<T>: Функция, которая возвращает Observable, которое выпускает результаты выборки значений, выпущенных исходным Observable, всякий раз, когда Observable-уведомление выпускает значение или завершается.

Описание

Это похоже на sampleTime, но выборка производится всякий раз, когда notifier ObservableInput выпускает значение.

Всякий раз, когда notifier ObservableInput выпускает значение, sample смотрит на исходное Observable и выпускает последнее значение, выпущенное им с момента предыдущей выборки, если с момента предыдущей выборки источник ничего не выпускал. На notifier подписываются сразу после подписки на Observable-выход.

Пример

При каждом клике производится выборка последнего значения таймера seconds

import { fromEvent, interval, sample } from 'rxjs';

const seconds = interval(1000);
const clicks = fromEvent(document, 'click');
const result = seconds.pipe(sample(clicks));

result.subscribe(x => console.log(x));

См. также

• audit
• debounce
• sampleTime
• throttle