Package 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, CloseSessionResultListener, FlightEndpointListener, GetSessionOptionsResultListener, NoOpStreamListener, SetSessionOptionsResultListener, SyncPutListener
Enclosing interface:
FlightProducer
public static interface FlightProducer.StreamListener<T>
Callbacks for pushing objects to a receiver.

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • 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.