Interface: AsyncQueuerState<TValue>

Type Parameters

TValue

Properties

activeItems

activeItems: TValue[];

activeItems: TValue[];

Defined in: async-queuer.ts:13

Items currently being processed by the queuer

addItemCount

addItemCount: number;

addItemCount: number;

Defined in: async-queuer.ts:17

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

errorCount

errorCount: number;

errorCount: number;

Defined in: async-queuer.ts:21

Number of task executions that have resulted in errors

executeCount

executeCount: number;

executeCount: number;

Defined in: async-queuer.ts:25

Number of times execute has been called

expirationCount

expirationCount: number;

expirationCount: number;

Defined in: async-queuer.ts:29

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

isEmpty

isEmpty: boolean;

isEmpty: boolean;

Defined in: async-queuer.ts:33

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

isExecuting

isExecuting: boolean;

isExecuting: boolean;

Defined in: async-queuer.ts:37

Whether the queuer is currently executing

isFull

isFull: boolean;

isFull: boolean;

Defined in: async-queuer.ts:41

Whether the queuer has reached its maximum capacity

isIdle

isIdle: boolean;

isIdle: boolean;

Defined in: async-queuer.ts:45

Whether the queuer is not currently processing any items

isRunning

isRunning: boolean;

isRunning: boolean;

Defined in: async-queuer.ts:49

Whether the queuer is active and will process items automatically

items

items: TValue[];

items: TValue[];

Defined in: async-queuer.ts:53

Array of items currently waiting to be processed

itemTimestamps

itemTimestamps: number[];

itemTimestamps: number[];

Defined in: async-queuer.ts:57

Timestamps when items were added to the queue for expiration tracking

lastResult

lastResult: any;

lastResult: any;

Defined in: async-queuer.ts:61

The result from the most recent task execution

pendingTick

pendingTick: boolean;

pendingTick: boolean;

Defined in: async-queuer.ts:65

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

rejectionCount

rejectionCount: number;

rejectionCount: number;

Defined in: async-queuer.ts:69

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

settledCount

settledCount: number;

settledCount: number;

Defined in: async-queuer.ts:73

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

size

size: number;

size: number;

Defined in: async-queuer.ts:77

Number of items currently in the queue

status

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

successCount: number;

successCount: number;

Defined in: async-queuer.ts:85

Number of task executions that have completed successfully