org.apache.arrow.flight

Interface FlightProducer.ServerStreamListener

All Superinterfaces:

OutboundStreamListener

Enclosing interface:

FlightProducer

public static interface FlightProducer.ServerStreamListener
extends OutboundStreamListener

An interface for sending Arrow data back to a client.

Method Summary

Modifier and Type	Method and Description
boolean	isCancelled() 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 Detail

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.