MCPcopy Index your code
hub / github.com/Effect-TS/effect / unbounded

Function unbounded

packages/effect/src/internal/queue.ts:375–379  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

373
374/** @internal */
375export const unbounded = <A>(): Effect.Effect<Queue.Queue<A>> =>
376 pipe(
377 core.sync(() => MutableQueue.unbounded<A>()),
378 core.flatMap((queue) => make(backingQueueFromMutableQueue(queue), droppingStrategy()))
379 )
380
381/** @internal */
382const unsafeMake = <A>(

Callers 1

matchFunction · 0.70

Calls 5

droppingStrategyFunction · 0.85
syncMethod · 0.80
pipeFunction · 0.70
makeFunction · 0.70

Tested by

no test coverage detected