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
  • item {T}
  • Returns: {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