Module org.apache.arrow.flight.core
Package org.apache.arrow.flight
Interface FlightProducer.ServerStreamListener
- All Superinterfaces:
OutboundStreamListener
- Enclosing interface:
- FlightProducer
An interface for sending Arrow data back to a client.
-
Method Summary
Modifier and TypeMethodDescriptionboolean
Check whether the call has been cancelled.void
setOnCancelHandler
(Runnable handler) Set a callback for when the client cancels a call, i.e.Methods inherited from interface org.apache.arrow.flight.OutboundStreamListener
completed, error, isReady, putMetadata, putNext, putNext, setOnReadyHandler, setUseZeroCopy, start, start, start
-
Method Details
-
isCancelled
boolean isCancelled()Check whether the call has been cancelled. If so, stop sending data. -
setOnCancelHandler
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.
-