21.293. Class GrpcSubmitterExtensions
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
Provides extension methods for building gRPC task requests.
public static class GrpcSubmitterExtensions
21.293.1. Inheritance
21.293.2. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
21.293.3. Methods
21.293.3.1. BuildRequests(IAsyncEnumerator<CreateLargeTaskRequest>, CancellationToken)
Builds a sequence of
public static IAsyncEnumerable<TaskRequest> BuildRequests(this IAsyncEnumerator<CreateLargeTaskRequest> enumerator, CancellationToken cancellationToken)
21.293.3.1.1. Parameters
enumerator IAsyncEnumerator<CreateLargeTaskRequest>
The asynchronous enumerator of
cancellationToken CancellationToken
The cancellation token to observe while waiting for the next element.
21.293.3.1.2. Returns
An asynchronous enumerable of
21.293.3.1.3. Exceptions
Thrown if the input sequence is in an invalid state, such as missing expected output keys, data dependencies, or chunks.