MCPcopy
hub / github.com/Effect-TS/effect / toQueue

Function toQueue

packages/effect/src/internal/channel.ts:2289–2291  ·  view source on GitHub ↗
(
  queue: Queue.Enqueue<Either.Either<Elem, Exit.Exit<Done, Err>>>
)

Source from the content-addressed store, hash-verified

2287
2288/** @internal */
2289export const toQueue = <Done, Err, Elem>(
2290 queue: Queue.Enqueue<Either.Either<Elem, Exit.Exit<Done, Err>>>
2291): Channel.Channel<never, Elem, never, Err, unknown, Done> => core.suspend(() => toQueueInternal(queue))
2292
2293/** @internal */
2294const toQueueInternal = <Err, Done, Elem>(

Callers 3

stream.tsFile · 0.85
bufferUnboundedFunction · 0.85
toPubSubFunction · 0.85

Calls 1

toQueueInternalFunction · 0.85

Tested by

no test coverage detected