Class AsyncStreamAdapter<T> (4.8.0)

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

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

Inheritance

object > AsyncStreamAdapter<T>

Implements

IAsyncStreamReader

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace

Google.Api.Gax.Grpc.Testing

Assembly

Google.Api.Gax.Grpc.Testing.dll

Type Parameter
Name	Description
`T`	The element type.

Constructors

AsyncStreamAdapter(IAsyncEnumerator<T>)

public AsyncStreamAdapter(IAsyncEnumerator<T> enumerator)

Wraps the given async enumerator as an async stream reader.

Parameter
Name	Description
`enumerator`	`IAsyncEnumerator` The enumerator to wrap

Properties

Current

public T Current { get; }

Gets the current element in the iteration.

Property Value
Type	Description
`T`

Methods

MoveNext(CancellationToken)

public Task<bool> MoveNext(CancellationToken cancellationToken)

Advances the reader to the next element in the sequence, returning the result asynchronously.

Parameter
Name	Description
`cancellationToken`	`CancellationToken` Cancellation token that can be used to cancel the operation.

Returns
Type	Description
`Taskbool`	Task containing the result of the operation: true if the reader was successfully advanced to the next element; false if the reader has passed the end of the sequence.