Class MiddlewareResponseStream<T>

Namespace

Apache.Arrow.Flight.Middleware.Interceptors

Assembly

Apache.Arrow.Flight.dll

public class MiddlewareResponseStream<T> : IAsyncStreamReader<T> where T : class

Type Parameters

T

Inheritance

object

MiddlewareResponseStream<T>

Implements

IAsyncStreamReader<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

MiddlewareResponseStream(IAsyncStreamReader<T>, AsyncServerStreamingCall<T>, List<IFlightClientMiddleware>)

public MiddlewareResponseStream(IAsyncStreamReader<T> inner, AsyncServerStreamingCall<T> call, List<IFlightClientMiddleware> middlewareList)

Parameters

inner IAsyncStreamReader<T>

call AsyncServerStreamingCall<T>

middlewareList List<IFlightClientMiddleware>

Properties

Current

Gets the current element in the iteration.

public T Current { get; }

Property Value

T

Methods

MoveNext(CancellationToken)

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

public Task<bool> MoveNext(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Cancellation token that can be used to cancel the operation.

Returns

Task<bool>

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.