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