Function bounded

packages/effect/src/internal/queue.ts:354–358

(requestedCapacity: number)

/** @internal */
export const bounded = <A>(requestedCapacity: number): Effect.Effect<Queue.Queue<A>> =>
  pipe(
    core.sync(() => MutableQueue.bounded<A>(requestedCapacity)),
    core.flatMap((queue) => make(backingQueueFromMutableQueue(queue), backPressureStrategy()))
  )

/** @internal */
export const dropping = <A>(requestedCapacity: number): Effect.Effect<Queue.Queue<A>> =>