Skip to content

IAsyncLossyQueue

Defined in: packages/data/src/queue/iasync-lossy-queue.ts:13

The async-backed sibling of ILossyQueue. Unlike blocking, eviction observability survives the collapse to async: Promise<readonly T[]> is genuinely different information from bare Promise<void> — the evicted items are real data, not just timing — so this sibling is legitimate where IAsyncBlockingQueue would not be.

T extends DefinedValue = DefinedValue

readonly capacity: number

Defined in: packages/data/src/collection/ibounded.ts:17

The maximum number of elements the collection can hold.

Note: Infinity is not a legal value here — an unbounded type omits this mixin.

ILossy.capacity


readonly overflowPolicy: OverflowPolicy

Defined in: packages/data/src/collection/ilossy.ts:20

Policy applied when the collection reaches its capacity.

ILossy.overflowPolicy

[asyncIterator](): AsyncIterator<T, any, any>

Defined in: node_modules/.store/typescript-npm-6.0.3-585eecd158/package/lib/lib.es2018.asynciterable.d.ts:36

AsyncIterator<T, any, any>

Omit.[asyncIterator]


clear(signal?): Promise<void>

Defined in: packages/data/src/collection/iasync-collection.ts:16

AbortSignal

Promise<void>

Omit.clear


count(signal?): Promise<number>

Defined in: packages/data/src/collection/iasync-collection.ts:14

AbortSignal

Promise<number>

Omit.count


dequeue(signal?): Promise<T | undefined>

Defined in: packages/data/src/queue/iasync-queue.ts:20

AbortSignal

Promise<T | undefined>

Omit.dequeue


enqueue(item, signal?): Promise<readonly T[]>

Defined in: packages/data/src/queue/iasync-lossy-queue.ts:15

T

AbortSignal

Promise<readonly T[]>


enqueueAll(items, signal?): Promise<readonly T[]>

Defined in: packages/data/src/queue/iasync-lossy-queue.ts:17

Iterable<T>

AbortSignal

Promise<readonly T[]>


front(signal?): Promise<T | undefined>

Defined in: packages/data/src/queue/iasync-queue.ts:22

AbortSignal

Promise<T | undefined>

Omit.front