take.md

Take

Берет только определенное количество значений, после чего завершается

💡 take является противоположным оператором оператора skip, если take берет n значений и закрывается, то skip пропускает эти значения

Сигнатура

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

Параметры

count

Количество значений которые нужно взять

Примеры

// RxJS v6+
import { of } from 'rxjs';
import { take } from 'rxjs/operators';

//emit 1,2,3,4,5
const source = of(1, 2, 3, 4, 5);
//take the first emitted value then complete
const example = source.pipe(take(1));
//output: 1
const subscribe = example.subscribe(val => console.log(val));

Полезные ссылки

• 📰 Официальная документация: take
• 📁 Исходный код: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/take.ts