Function waitForSize

packages/effect/test/Queue.test.ts:17–19

(queue: Queue.Queue<A>, size: number)

}

export const waitForSize = <A>(queue: Queue.Queue<A>, size: number): Effect.Effect<number> => {
  return waitForValue(Queue.size(queue), size)
}

describe("Queue", () => {
  it.effect("bounded - offerAll returns true when there is enough space", () =>