Represents AsyncQueue.
new AsyncQueue(): AsyncQueue<T, K, R>
Returns:
AsyncQueue<T, K, R>M
add
add(item, callback): void
Attributes
Processes the provided item.
clear(): void
Returns:
voiddecreaseParallelism(): void
Returns:
voidDecrease parallelism.
getContext(): string
Returns:
stringReturns context of execution.
increaseParallelism(): void
Returns:
voidIncrease parallelism.
invalidate(item): void
Attributes
item:
TReturns:
voidProcesses the provided item.
isDone(item): boolean
Attributes
item:
TReturns:
booleanChecks whether this async queue is done.
isProcessing(item): boolean
Attributes
item:
TReturns:
booleanChecks whether this async queue is processing.
isQueued(item): boolean
Attributes
item:
TReturns:
booleanChecks whether this async queue is queued.
setContext(value): void
Attributes
Updates context using the provided value.
M
stop
stop(): void
Returns:
voidDescribes how this stop operation behaves.
waitFor(item, callback): void
Attributes
Waits for an already started item
added(t): void
Attributes
t:
TReturns:
voidbeforeAdd(t): void
Attributes
t:
TReturns:
voidbeforeStart(t): void
Attributes
t:
TReturns:
voidresult(t, arg1, arg2): void
Attributes
started(t): void
Attributes
t:
TReturns:
voidAttributes