Skip to content

Welshman Docs / @welshman/lib / TaskQueue

Class: TaskQueue<Item>

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

Type Parameters

Item

Item

Constructors

Constructor

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

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

Parameters

options

TaskQueueOptions<Item>

Returns

TaskQueue<Item>

Properties

_subs

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

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

Parameters

item

Item

Returns

void


isPaused

isPaused: boolean = false

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


isProcessing

isProcessing: boolean = false

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


items

items: Item[] = []

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


options

readonly options: TaskQueueOptions<Item>

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

Methods

clear()

clear(): void

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

Returns

void


process()

process(): void

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

Returns

void


push()

push(item): void

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

Parameters

item

Item

Returns

void


remove()

remove(item): void

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

Parameters

item

Item

Returns

void


start()

start(): void

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

Returns

void


stop()

stop(): void

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

Returns

void


subscribe()

subscribe(subscriber): () => void

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

Parameters

subscriber

(item) => void

Returns

(): void

Returns

void