Class EventsClientExt

Namespace: ArmoniK.Api.Client
Assembly: ArmoniK.Api.Client.dll

extensions methods

[PublicAPI]
public static class EventsClientExt

Inheritance

object ← EventsClientExt

Inherited Members

object.Equals(object), object.Equals(object, object), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object, object), object.ToString()

Methods

WaitForResultsAsync(EventsClient, string, ICollection<string>, CancellationToken)

Wait until the given results are completed

[PublicAPI]
[Obsolete("Use the overload with the bucket size and the parallelism")]
public static Task WaitForResultsAsync(this Events.EventsClient client, string sessionId, ICollection<string> resultIds, CancellationToken cancellationToken = default)

Parameters

client Events.EventsClient

gRPC result client

sessionId string

The session ID in which the results are located

resultIds ICollection<string>

A collection of results to wait for

cancellationToken CancellationToken

Token used to cancel the execution of the method

Returns

Task

Exceptions

Exception

if a result is aborted

WaitForResultsAsync(EventsClient, string, ICollection<string>, int, int, CancellationToken)

Wait until the given results are completed

[PublicAPI]
public static Task WaitForResultsAsync(this Events.EventsClient client, string sessionId, ICollection<string> resultIds, int bucket_size = 100, int parallelism = 1, CancellationToken cancellationToken = default)