Skip to content

Welshman Docs / @welshman/lib / TaskQueue

Class: TaskQueue<Item> ​

Defined in: packages/lib/src/TaskQueue.ts:10

Type Parameters ​

Item ​

Item

Constructors ​

Constructor ​

new TaskQueue<Item>(options): TaskQueue<Item>

Defined in: packages/lib/src/TaskQueue.ts:16

Parameters ​

options ​

TaskQueueOptions<Item>

Returns ​

TaskQueue<Item>

Properties ​

_subs ​

_subs: (item) => void[] = []

Defined in: packages/lib/src/TaskQueue.ts:11

Parameters ​

item ​

Item

Returns ​

void


isPaused ​

isPaused: boolean = false

Defined in: packages/lib/src/TaskQueue.ts:13


isProcessing ​

isProcessing: boolean = false

Defined in: packages/lib/src/TaskQueue.ts:14


items ​

items: Item[] = []

Defined in: packages/lib/src/TaskQueue.ts:12


options ​

readonly options: TaskQueueOptions<Item>

Defined in: packages/lib/src/TaskQueue.ts:16

Methods ​

clear() ​

clear(): void

Defined in: packages/lib/src/TaskQueue.ts:102

Returns ​

void


process() ​

process(): void

Defined in: packages/lib/src/TaskQueue.ts:61

Returns ​

void


push() ​

push(item): void

Defined in: packages/lib/src/TaskQueue.ts:18

Parameters ​

item ​

Item

Returns ​

void


remove() ​

remove(item): void

Defined in: packages/lib/src/TaskQueue.ts:49

Parameters ​

item ​

Item

Returns ​

void


start() ​

start(): void

Defined in: packages/lib/src/TaskQueue.ts:97

Returns ​

void


stop() ​

stop(): void

Defined in: packages/lib/src/TaskQueue.ts:93

Returns ​

void


subscribe() ​

subscribe(subscriber): () => void

Defined in: packages/lib/src/TaskQueue.ts:53

Parameters ​

subscriber ​

(item) => void

Returns ​

(): void

Returns ​

void