Method takeN

packages/effect/src/internal/groupBy.ts:381–383

(n: number)

  }

  takeN(n: number): Effect.Effect<Chunk.Chunk<B>> {
    return pipe(Queue.takeN(this.dequeue, n), Effect.map(Chunk.map((a) => this.f(a))))
  }

  poll(): Effect.Effect<Option.Option<B>> {
    return pipe(Queue.poll(this.dequeue), Effect.map(Option.map((a) => this.f(a))))