Skip to content

IWaitableQueue

Defined in: packages/data/src/queue/iwaitable-queue.ts:11

The blocking sibling of IQueue: waits for capacity instead of throwing when the queue is full. The inherited enqueue throws — this adds a way to wait, it does not change the way to fail.

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.

IBounded.capacity

[iterator](): Iterator<T, any, any>

Defined in: node_modules/.store/typescript-npm-6.0.3-585eecd158/package/lib/lib.es2015.iterable.d.ts:47

Iterator<T, any, any>

IQueue.[iterator]


clear(): void

Defined in: packages/data/src/collection/icollection.ts:23

Removes all elements from the collection.

void

IQueue.clear


count(): number

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

The number of elements in the collection.

A method, not a getter: its async counterpart needs a round trip to the backing store, and a member must have the same shape in both.

number

IQueue.count


dequeue(): T | undefined

Defined in: packages/data/src/queue/iqueue.ts:38

Removes and returns the item at the front of the queue.

T | undefined

The item at the front of the queue, or undefined if the queue is empty.

IQueue.dequeue


enqueue(item): void

Defined in: packages/data/src/queue/iqueue.ts:22

Adds an item to the rear of the queue.

T

The item to add to the queue.

void

IQueue.enqueue


enqueueAll(items): void

Defined in: packages/data/src/queue/iqueue.ts:30

Adds every item to the rear of the queue, in array order, so the last one is the last to be dequeued.

readonly T[]

The items to add to the queue.

void

IQueue.enqueueAll


front(): T | undefined

Defined in: packages/data/src/queue/iqueue.ts:46

Returns the item at the front of the queue without removing it.

T | undefined

The item at the front of the queue, or undefined if the queue is empty.

IQueue.front


waitEnqueue(item, signal?): Promise<void>

Defined in: packages/data/src/queue/iwaitable-queue.ts:19

Same as enqueue, but waits for capacity if the operation would exceed it.

T

AbortSignal | null

Optional abort signal to cancel the operation.

Promise<void>

IQueue.enqueue


waitEnqueueAll(items, signal?): Promise<void>

Defined in: packages/data/src/queue/iwaitable-queue.ts:29

Same as enqueueAll, but waits for capacity if the operation would exceed it. The whole batch lands at once, never interleaved with another waiter’s.

Iterable<T>

AbortSignal | null

Optional abort signal to cancel the operation.

Promise<void>

IQueue.enqueueAll