take

Emits only the first count values emitted by the source Observable.

Takes the first count values from the source, then completes.

take returns an Observable that emits only the first count values emitted by the source Observable. If the source emits fewer than count values then all of its values are emitted. After that, it completes, regardless if the source completes.

Example

Take the first 5 seconds of an infinite 1-second interval Observable

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

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

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

[src]

§Type Parameters

[src]

§Parameters

count: number

[src]

The maximum number of next values to emit.

§Return Type

MonoTypeOperatorFunction<T>

[src]

A function that returns an Observable that emits only the first count values emitted by the source Observable, or all of the values from the source if the source emits fewer than count values.