take

Выпускает только первые count значений, испускаемых исходным Observable.

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

Параметры

count

number

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

Возвращает

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

Описание

Берет первые count значения из источника, затем завершает.

take возвращает Observable, который выпускает только первые count значений, испускаемых исходным Observable. Если источник выпускает меньше count значений, то все его значения выпускаются. После этого он завершается, независимо от того, завершается ли источник.

Пример

Возьмите первые 5 секунд из бесконечного Observable с интервалом 1 секунда

import { interval, take } from 'rxjs';

const intervalCount = interval(1000);
const takeFive = intervalCount.pipe(take(5));
takeFive.subscribe(x => console.log(x));

// Logs:
// 0
// 1
// 2
// 3
// 4

См. также

• takeLast
• takeUntil
• takeWhile
• skip