Interface FlightProducer.ServerStreamListener

All Superinterfaces:
Enclosing interface:

public static interface FlightProducer.ServerStreamListener extends OutboundStreamListener
An interface for sending Arrow data back to a client.
  • Method Details

    • isCancelled

      boolean isCancelled()
      Check whether the call has been cancelled. If so, stop sending data.
    • setOnCancelHandler

      void setOnCancelHandler(Runnable handler)
      Set a callback for when the client cancels a call, i.e. isCancelled() has become true.

      Note that this callback may only be called some time after isCancelled() becomes true, and may never be called if all executor threads on the server are busy, or the RPC method body is implemented in a blocking fashion.