23.288. 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
23.288.1. Inheritance
23.288.2. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
23.288.3. Methods
23.288.3.1. BuildRequests(IAsyncEnumerator<CreateLargeTaskRequest>, CancellationToken)
Builds a sequence of
public static IAsyncEnumerable<TaskRequest> BuildRequests(this IAsyncEnumerator<CreateLargeTaskRequest> enumerator, CancellationToken cancellationToken)
23.288.3.1.1. Parameters
enumerator IAsyncEnumerator<CreateLargeTaskRequest>
The asynchronous enumerator of
cancellationToken CancellationToken
The cancellation token to observe while waiting for the next element.
23.288.3.1.2. Returns
An asynchronous enumerable of
23.288.3.1.3. Exceptions
Thrown if the input sequence is in an invalid state, such as missing expected output keys, data dependencies, or chunks.