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

Class BackingQueueFromMutableQueue

packages/effect/src/internal/queue.ts:411–432  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

409
410/** @internal */
411export class BackingQueueFromMutableQueue<in out A> implements Queue.BackingQueue<A> {
412 readonly [BackingQueueTypeId] = backingQueueVariance
413 constructor(readonly mutable: MutableQueue.MutableQueue<A>) {}
414 poll<Def>(def: Def): A | Def {
415 return MutableQueue.poll(this.mutable, def)
416 }
417 pollUpTo(limit: number): Chunk.Chunk<A> {
418 return MutableQueue.pollUpTo(this.mutable, limit)
419 }
420 offerAll(elements: Iterable<A>): Chunk.Chunk<A> {
421 return MutableQueue.offerAll(this.mutable, elements)
422 }
423 offer(element: A): boolean {
424 return MutableQueue.offer(this.mutable, element)
425 }
426 capacity(): number {
427 return MutableQueue.capacity(this.mutable)
428 }
429 length(): number {
430 return MutableQueue.length(this.mutable)
431 }
432}
433
434/** @internal */
435export const backingQueueFromMutableQueue = <A>(mutable: MutableQueue.MutableQueue<A>): Queue.BackingQueue<A> =>

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected