Skip to content
Orleans logoMicrosoft Orleans

IAsyncEnumerableGrainExtension Methods

Grain extension interface for grains which return System.Collections.Generic.IAsyncEnumerable from grain methods.

DisposeAsync(Guid)

abstract
[Orleans.Concurrency.AlwaysInterleave]
public abstract ValueTask DisposeAsync(Guid requestId)
Disposes an System.Collections.Generic.IAsyncEnumerable value.

Parameters

requestIdGuid
The request id, generated by the caller.

Returns

A task representing the operation.

MoveNext(Guid, CancellationToken)

abstract
View source
[Orleans.Concurrency.AlwaysInterleave]
public abstract ValueTask<(EnumerationResult Status, object Value)> IAsyncEnumerableGrainExtension.MoveNext<T>(Guid requestId, CancellationToken cancellationToken)
Continues enumerating an System.Collections.Generic.IAsyncEnumerable value.

Parameters

requestIdGuid
The request id, generated by the caller.
cancellationTokenCancellationToken
The cancellation token.

Returns

The result of enumeration

MoveNext(Guid)

virtual
View source
[Orleans.Concurrency.AlwaysInterleave]
public virtual ValueTask<(EnumerationResult Status, object Value)> IAsyncEnumerableGrainExtension.MoveNext<T>(Guid requestId)
Continues enumerating an System.Collections.Generic.IAsyncEnumerable value.

Parameters

requestIdGuid
The request id, generated by the caller.

Returns

The result of enumeration

StartEnumeration(Guid, IAsyncEnumerableRequest<T>, CancellationToken)

abstract
View source
[Orleans.Concurrency.AlwaysInterleave]
public abstract ValueTask<(EnumerationResult Status, object Value)> IAsyncEnumerableGrainExtension.StartEnumeration<T>(Guid requestId, IAsyncEnumerableRequest<T> request, CancellationToken cancellationToken)
Invokes an System.Collections.Generic.IAsyncEnumerable request and begins enumeration.

Parameters

requestIdGuid
The request id, generated by the caller.
requestIAsyncEnumerableRequest<T>
The request.
cancellationTokenCancellationToken
The cancellation token.

Returns

The result of enumeration

StartEnumeration(Guid, IAsyncEnumerableRequest<T>)

virtual
View source
[Orleans.Concurrency.AlwaysInterleave]
public virtual ValueTask<(EnumerationResult Status, object Value)> IAsyncEnumerableGrainExtension.StartEnumeration<T>(Guid requestId, IAsyncEnumerableRequest<T> request)
Invokes an System.Collections.Generic.IAsyncEnumerable request and begins enumeration.

Parameters

requestIdGuid
The request id, generated by the caller.
requestIAsyncEnumerableRequest<T>
The request.

Returns

The result of enumeration