Class FlightRecordBatchDuplexStreamingCall

Namespace

Apache.Arrow.Flight.Client

Assembly

Apache.Arrow.Flight.dll

public class FlightRecordBatchDuplexStreamingCall : IDisposable

Inheritance

object

FlightRecordBatchDuplexStreamingCall

Implements

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

RequestStream

Async stream to send streaming requests.

public FlightClientRecordBatchStreamWriter RequestStream { get; }

Property Value

FlightClientRecordBatchStreamWriter

ResponseHeadersAsync

Asynchronous access to response headers.

public Task<Metadata> ResponseHeadersAsync { get; }

Property Value

Task<Metadata>

ResponseStream

Async stream to read streaming responses.

public IAsyncStreamReader<FlightPutResult> ResponseStream { get; }

Property Value

IAsyncStreamReader<FlightPutResult>

Methods

Dispose()

Provides means to cleanup after the call. If the call has already finished normally (response stream has been fully read), doesn't do anything. Otherwise, requests cancellation of the call which should terminate all pending async operations associated with the call. As a result, all resources being used by the call should be released eventually.

public void Dispose()

Remarks

Normally, there is no need for you to dispose the call unless you want to utilize the "Cancel" semantics of invoking Dispose.

GetStatus()

Gets the call status if the call has already finished. Throws InvalidOperationException otherwise.

public Status GetStatus()

Returns

Status

GetTrailers()

Gets the call trailing metadata if the call has already finished. Throws InvalidOperationException otherwise.

public Metadata GetTrailers()

Returns

Metadata