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:7

Type Parameters

TValue

Properties

activeItems

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

Defined in: async-queuer.ts:11

Items currently being processed by the queuer


addItemCount

ts
addItemCount: number;
addItemCount: number;

Defined in: async-queuer.ts:15

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


errorCount

ts
errorCount: number;
errorCount: number;

Defined in: async-queuer.ts:19

Number of task executions that have resulted in errors


expirationCount

ts
expirationCount: number;
expirationCount: number;

Defined in: async-queuer.ts:23

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


isEmpty

ts
isEmpty: boolean;
isEmpty: boolean;

Defined in: async-queuer.ts:27

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


isFull

ts
isFull: boolean;
isFull: boolean;

Defined in: async-queuer.ts:31

Whether the queuer has reached its maximum capacity


isIdle

ts
isIdle: boolean;
isIdle: boolean;

Defined in: async-queuer.ts:35

Whether the queuer is not currently processing any items


isRunning

ts
isRunning: boolean;
isRunning: boolean;

Defined in: async-queuer.ts:39

Whether the queuer is active and will process items automatically


items

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

Defined in: async-queuer.ts:43

Array of items currently waiting to be processed


itemTimestamps

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

Defined in: async-queuer.ts:47

Timestamps when items were added to the queue for expiration tracking


lastResult

ts
lastResult: any;
lastResult: any;

Defined in: async-queuer.ts:51

The result from the most recent task execution


pendingTick

ts
pendingTick: boolean;
pendingTick: boolean;

Defined in: async-queuer.ts:55

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


rejectionCount

ts
rejectionCount: number;
rejectionCount: number;

Defined in: async-queuer.ts:59

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


settledCount

ts
settledCount: number;
settledCount: number;

Defined in: async-queuer.ts:63

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


size

ts
size: number;
size: number;

Defined in: async-queuer.ts:67

Number of items currently in the queue


status

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

Defined in: async-queuer.ts:71

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


successCount

ts
successCount: number;
successCount: number;

Defined in: async-queuer.ts:75

Number of task executions that have completed successfully