Function make

packages/effect/src/internal/queue.ts:393–408

(
  queue: Queue.BackingQueue<A>,
  strategy: Queue.Strategy<A>
)

/** @internal */
export const make = <A>(
  queue: Queue.BackingQueue<A>,
  strategy: Queue.Strategy<A>
): Effect.Effect<Queue.Queue<A>> =>
  pipe(
    core.deferredMake<void>(),
    core.map((deferred) =>
      unsafeMake(
        queue,
        MutableQueue.unbounded(),
        deferred,
        MutableRef.make(false),
        strategy
      )
    )
  )

/** @internal */
export class BackingQueueFromMutableQueue<in out A> implements Queue.BackingQueue<A> {