Function take

take(count: number): <T>(source: AsyncIterable<T>) => Stream<T>
Emits at most count values, then closes upstream.

Upstream cleanup begins before the final (count-th) value is delivered, while downstream callback signals remain active. take(0) completes immediately without opening upstream.
Parameters
- count: number
Returns <T>(source: AsyncIterable<T>) => Stream<T>

Throws
If count is not a non-negative safe integer.
take<T>(count: number): Operator<T, T>
Emits at most count values, then closes upstream.

Upstream cleanup begins before the final (count-th) value is delivered, while downstream callback signals remain active. take(0) completes immediately without opening upstream.
Type Parameters
- T
Parameters
- count: number
Returns Operator<T, T>

Throws
If count is not a non-negative safe integer.