Method takeN

packages/effect/src/PubSub.ts:2788–2795

(n: number)

    return value as A
  }
  takeN(n: number): Array<A> {
    const len = Math.min(n, this.remaining)
    const items = new Array(len)
    for (let i = 0; i < len; i++) {
      items[i] = this.take()!
    }
    return items
  }
  takeAll(): Array<A> {
    return this.takeN(this.remaining)
  }