On this page

new AsyncQueue(): AsyncQueue
Returns:<AsyncQueue>
< <T> , <K> , <R> >
Attributes
hooks:<object>
add(item, callback): void
  • item {T}
  • callback <CallbackAsyncQueue><<R>>
  • Returns: <void>

Processes the provided item.


clear(): void
Returns:<void>

decreaseParallelism(): void
Returns:<void>

Decrease parallelism.


getContext(): string
Returns:<string>

Returns context of execution.


increaseParallelism(): void
Returns:<void>

Increase parallelism.


invalidate(item): void

Processes the provided item.


isDone(item): void

Checks whether this async queue is done.


isProcessing(item): void

Checks whether this async queue is processing.


isQueued(item): void

Checks whether this async queue is queued.


setContext(value): void
Attributes
value:<string>
Returns:<void>

Updates context using the provided value.


stop(): void
Returns:<void>

Describes how this stop operation behaves.


waitFor(item, callback): void
  • item {T}
  • callback <CallbackAsyncQueue><<R>>
  • Returns: <void>

Waits for an already started item