fx-flow v0.7.0 / pipe/strict / consume

Function: consume()

consume<A>(iterable, length?): IterableReturnValue<A, void>

Consumes the given length of Iterable/AsyncIterable.

Type parameters

• A extends UniversalIterable

Parameters

• iterable: A

• length?: number

Returns

IterableReturnValue<A, void>

Example

pipe(userList, toAsync, peek(queryUserInfo), consume(Infinity))

More examples

Source

packages/core/src/pipe/strict/consume.ts:34