org.apache.arrow.flight

Interface FlightProducer.StreamListener<T>

Type Parameters:

T - Type of the values in the stream.

All Known Subinterfaces:

FlightClient.PutListener

All Known Implementing Classes:

AsyncPutListener, NoOpStreamListener, SyncPutListener

Enclosing interface:

FlightProducer

public static interface FlightProducer.StreamListener<T>

Callbacks for pushing objects to a receiver.

Method Summary

Modifier and Type	Method and Description
void	onCompleted() Indicate that the transmission is finished.
void	onError(Throwable t) Indicate an error to the client.
void	onNext(T val) Send the next value to the client.

Method Detail

onNext

void onNext(T val)

Send the next value to the client.

onError

void onError(Throwable t)

Indicate an error to the client.

Terminates the stream; do not call onCompleted().

onCompleted

void onCompleted()

Indicate that the transmission is finished.