Function sliding

packages/effect/src/internal/queue.ts:368–372

(requestedCapacity: number)

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

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