Skip to content

Welshman Docs / @welshman/lib / TaskQueue

Class: TaskQueue<Item> ​

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

Type Parameters ​

Item ​

Item

Constructors ​

Constructor ​

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

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

Parameters ​

options ​

TaskQueueOptions<Item>

Returns ​

TaskQueue<Item>

Properties ​

_subs ​

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

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

Parameters ​

item ​

Item

Returns ​

void


isPaused ​

isPaused: boolean = false

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


isProcessing ​

isProcessing: boolean = false

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


items ​

items: Item[] = []

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


options ​

readonly options: TaskQueueOptions<Item>

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

Methods ​

clear() ​

clear(): void

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

Returns ​

void


process() ​

process(): Promise<void>

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

Returns ​

Promise<void>


push() ​

push(item): void

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

Parameters ​

item ​

Item

Returns ​

void


remove() ​

remove(item): void

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

Parameters ​

item ​

Item

Returns ​

void


start() ​

start(): void

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

Returns ​

void


stop() ​

stop(): void

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

Returns ​

void


subscribe() ​

subscribe(subscriber): () => void

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

Parameters ​

subscriber ​

(item) => void

Returns ​

(): void

Returns ​

void