takeLast

Ожидает завершения источника, затем испускает последние N значений из источника, как указано в аргументе count.

takeLast<T>(count: number): MonoTypeOperatorFunction<T>

Параметры

count

number

Максимальное количество значений для испускания с конца последовательности значений, испускаемых источником Observable.

Возвращает

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

Описание

takeLast приводит к observable, который будет хранить значения до count значений в памяти, до завершения источника. Затем он передает все значения в памяти потребителю в порядке их получения из источника, затем уведомляет потребителя о завершении.

Если по какой-то причине источник завершается до достижения значения count, переданного в takeLast, все полученные до этого момента значения испускаются, а затем уведомляется о завершении.

Предупреждение: Использование takeLast с observable, который никогда не завершается, приведет к observable, который никогда не испустит значение.

Пример

Взять последние 3 значения из Observable с многими значениями

import { range, takeLast } from 'rxjs';

const many = range(1, 100);
const lastThree = many.pipe(takeLast(3));
lastThree.subscribe(x => console.log(x));

См. также

• take
• takeUntil
• takeWhile
• skip