On this page

new AsyncQueue(): AsyncQueue< T, K, R >
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