Interface IAsyncJobQueue<T>

A queue for long-existing System.Collections.Generic.IAsyncEnumerable<T> that represent a collection of long running resumable jobs.

Inherited Members
Namespace: Snowflake.Extensibility.Queueing
Assembly: Snowflake.Framework.Primitives.dll
Syntax
public interface IAsyncJobQueue<T> : IAsyncJobQueue<IAsyncEnumerable<T>, T>, IAsyncJobQueue
Type Parameters
Name Description
T

The type of elements in the enumerable.

Methods

TryRemoveSource(Guid, out IAsyncEnumerable<T>)

Tries to remove the System.Collections.Generic.IAsyncEnumerable<T> as it was added to the job queue. This will only succeed if there are no active jobs for the enumerable in the queue.

Declaration
bool TryRemoveSource(Guid jobId, out IAsyncEnumerable<T> asyncEnumerable)
Parameters
Type Name Description
System.Guid jobId

The jobId
System.Collections.Generic.IAsyncEnumerable<T> asyncEnumerable

The async enumerable that is removed, or the empty enumerable if the result is false. This is unlike TryRemoveSource(Guid, out TAsyncEnumerable), which will return null instead of a enumerable.
Returns
Type Description
System.Boolean

If the enumerable was successfully removed.