Interface IAsyncQueueInstance

Non-generic interface for tracking all IAsyncQueueBase<TItem> instances at runtime.

Namespace: SuperOffice.Threading
Assembly: SoCore.dll
Syntax
public interface IAsyncQueueInstance

Properties

HasItemsInTheQueue

True if there are items in the queue or items currently being processed

Declaration
bool HasItemsInTheQueue { get; }
Property Value
Type Description
bool

Methods

WaitForInFlightItemsAsync(CancellationToken)

Wait for items that are currently being processed (in-flight) to complete. Unlike WaitForItemsInQueueToBeProcessedAsync(CancellationToken), this does NOT wait for items still sitting in the queue.

Declaration
Task WaitForInFlightItemsAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task

WaitForItemsInQueueToBeProcessedAsync(CancellationToken)

Wait for all items currently in the queue or currently being processed to be processed.

Declaration
Task WaitForItemsInQueueToBeProcessedAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task

Extension Methods