consume() function

消费给定数量的 Iterable/AsyncIterable。如果数字为空,则消费全部。

Signature:

declare function consume<
  A extends Iterable<unknown> | AsyncIterable<unknown>,
  B extends number,
>(iterator: A, n?: B): ReturnValueType<A, void>;

Example

const iterator = (function* () {
  yield 1;
  yield 2;
  yield 3;
})();
consume(iterator, 2);
iterator.next(); // {value:3, done:false}
iterator.next(); // {value:undefined, done:true}

// with pipe
pipe(range(10), peek(updateApi), concurrent(5), consume);

Open Source Code