Class AsyncStreamAdapter<T> (4.2.0) 

public sealed class AsyncStreamAdapter<T> : IAsyncStreamReader<T>

Simple adapter to allow an to be used as a gRPC . Note that cancellation is not fully supported, due to differences between the two interfaces.

Inheritance

Object > AsyncStreamAdapter<T>

Namespace

Google.Api.Gax.Grpc.Testing

Assembly

Google.Api.Gax.Grpc.Testing.dll

Type Parameter

NameDescription
T

The element type.

Constructors

AsyncStreamAdapter(IAsyncEnumerator<T>)

public AsyncStreamAdapter(IAsyncEnumerator<T> enumerator)

Wraps the given async enumerator as an async stream reader.

Parameter
NameDescription
enumeratorIAsyncEnumerator<T>

The enumerator to wrap

Properties

Current

public T Current { get; }
Property Value
TypeDescription
T

Methods

MoveNext(CancellationToken)

public async Task<bool> MoveNext(CancellationToken cancellationToken)
Parameter
NameDescription
cancellationTokenCancellationToken
Returns
TypeDescription
Task<Boolean>