Framework
Version
Debouncer API Reference
Throttler API Reference
Rate Limiter API Reference
Queue API Reference
Batcher API Reference

AsyncQueuerState

Interface: AsyncQueuerState<TValue>

Defined in: async-queuer.ts:9

Type Parameters

TValue

Properties

activeItems

ts
activeItems: TValue[];
activeItems: TValue[];

Defined in: async-queuer.ts:13

Items currently being processed by the queuer


addItemCount

ts
addItemCount: number;
addItemCount: number;

Defined in: async-queuer.ts:17

Number of times addItem has been called (for reduction calculations)


errorCount

ts
errorCount: number;
errorCount: number;

Defined in: async-queuer.ts:21

Number of task executions that have resulted in errors


executeCount

ts
executeCount: number;
executeCount: number;

Defined in: async-queuer.ts:25

Number of times execute has been called


expirationCount

ts
expirationCount: number;
expirationCount: number;

Defined in: async-queuer.ts:29

Number of items that have been removed from the queue due to expiration


isEmpty

ts
isEmpty: boolean;
isEmpty: boolean;

Defined in: async-queuer.ts:33

Whether the queuer has no items to process (items array is empty)


isExecuting

ts
isExecuting: boolean;
isExecuting: boolean;

Defined in: async-queuer.ts:37

Whether the queuer is currently executing


isFull

ts
isFull: boolean;
isFull: boolean;

Defined in: async-queuer.ts:41

Whether the queuer has reached its maximum capacity


isIdle

ts
isIdle: boolean;
isIdle: boolean;

Defined in: async-queuer.ts:45

Whether the queuer is not currently processing any items


isRunning

ts
isRunning: boolean;
isRunning: boolean;

Defined in: async-queuer.ts:49

Whether the queuer is active and will process items automatically


items

ts
items: TValue[];
items: TValue[];

Defined in: async-queuer.ts:53

Array of items currently waiting to be processed


itemTimestamps

ts
itemTimestamps: number[];
itemTimestamps: number[];

Defined in: async-queuer.ts:57

Timestamps when items were added to the queue for expiration tracking


lastResult

ts
lastResult: any;
lastResult: any;

Defined in: async-queuer.ts:61

The result from the most recent task execution


pendingTick

ts
pendingTick: boolean;
pendingTick: boolean;

Defined in: async-queuer.ts:65

Whether the queuer has a pending timeout for processing the next item


rejectionCount

ts
rejectionCount: number;
rejectionCount: number;

Defined in: async-queuer.ts:69

Number of items that have been rejected from being added to the queue


settledCount

ts
settledCount: number;
settledCount: number;

Defined in: async-queuer.ts:73

Number of task executions that have completed (either successfully or with errors)


size

ts
size: number;
size: number;

Defined in: async-queuer.ts:77

Number of items currently in the queue


status

ts
status: "idle" | "running" | "stopped";
status: "idle" | "running" | "stopped";

Defined in: async-queuer.ts:81

Current processing status - 'idle' when not processing, 'running' when active, 'stopped' when paused


successCount

ts
successCount: number;
successCount: number;

Defined in: async-queuer.ts:85

Number of task executions that have completed successfully