Edit

IAsyncEnumerableGrainExtension.StartEnumeration Method

Definition

Overloads

StartEnumeration<T>(Guid, IAsyncEnumerableRequest<T>)

Invokes an IAsyncEnumerable<T> request and begins enumeration.

[Orleans.Concurrency.AlwaysInterleave]
public virtual System.Threading.Tasks.ValueTask<(Orleans.Runtime.EnumerationResult Status, object Value)> StartEnumeration<T>(Guid requestId, Orleans.Runtime.IAsyncEnumerableRequest<T> request);
[Orleans.Concurrency.AlwaysInterleave]
public System.Threading.Tasks.ValueTask<(Orleans.Runtime.EnumerationResult Status, object Value)> StartEnumeration<T>(Guid requestId, Orleans.Runtime.IAsyncEnumerableRequest<T> request);
[<Orleans.Concurrency.AlwaysInterleave>]
abstract member StartEnumeration : Guid * Orleans.Runtime.IAsyncEnumerableRequest<'T> -> System.Threading.Tasks.ValueTask<ValueTuple<Orleans.Runtime.EnumerationResult, obj>>
override this.StartEnumeration : Guid * Orleans.Runtime.IAsyncEnumerableRequest<'T> -> System.Threading.Tasks.ValueTask<ValueTuple<Orleans.Runtime.EnumerationResult, obj>>
[<Orleans.Concurrency.AlwaysInterleave>]
abstract member StartEnumeration : Guid * Orleans.Runtime.IAsyncEnumerableRequest<'T> -> System.Threading.Tasks.ValueTask<ValueTuple<Orleans.Runtime.EnumerationResult, obj>>
Public Overridable Function StartEnumeration(Of T) (requestId As Guid, request As IAsyncEnumerableRequest(Of T)) As ValueTask(Of ValueTuple(Of EnumerationResult, Object))
Public Function StartEnumeration(Of T) (requestId As Guid, request As IAsyncEnumerableRequest(Of T)) As ValueTask(Of ValueTuple(Of EnumerationResult, Object))

Type Parameters

T

The element type.

Parameters

requestId
Guid

The request id, generated by the caller.

request
IAsyncEnumerableRequest<T>

The request.

Returns

The result of enumeration

Attributes

Applies to

StartEnumeration<T>(Guid, IAsyncEnumerableRequest<T>, CancellationToken)

Invokes an IAsyncEnumerable<T> request and begins enumeration.

[Orleans.Concurrency.AlwaysInterleave]
public System.Threading.Tasks.ValueTask<(Orleans.Runtime.EnumerationResult Status, object Value)> StartEnumeration<T>(Guid requestId, Orleans.Runtime.IAsyncEnumerableRequest<T> request, System.Threading.CancellationToken cancellationToken);
[<Orleans.Concurrency.AlwaysInterleave>]
abstract member StartEnumeration : Guid * Orleans.Runtime.IAsyncEnumerableRequest<'T> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<ValueTuple<Orleans.Runtime.EnumerationResult, obj>>
Public Function StartEnumeration(Of T) (requestId As Guid, request As IAsyncEnumerableRequest(Of T), cancellationToken As CancellationToken) As ValueTask(Of ValueTuple(Of EnumerationResult, Object))

Type Parameters

T

The element type.

Parameters

requestId
Guid

The request id, generated by the caller.

request
IAsyncEnumerableRequest<T>

The request.

cancellationToken
CancellationToken

The cancellation token.

Returns

The result of enumeration

Attributes

Applies to