java.lang.Object
org.apache.arrow.flight.sql.FlightEndpointListener
- All Implemented Interfaces:
FlightProducer.StreamListener<FlightEndpoint>
public class FlightEndpointListener
extends Object
implements FlightProducer.StreamListener<FlightEndpoint>
Typed StreamListener for renewFlightEndpoint.
-
Method Summary
Modifier and TypeMethodDescriptionvoidIndicate that the transmission is finished.voidIndicate an error to the client.voidonNext(FlightEndpoint val) Send the next value to the client.
-
Method Details
-
onNext
Description copied from interface:FlightProducer.StreamListenerSend the next value to the client.- Specified by:
onNextin interfaceFlightProducer.StreamListener<FlightEndpoint>
-
onError
Description copied from interface:FlightProducer.StreamListenerIndicate an error to the client.Terminates the stream; do not call
FlightProducer.StreamListener.onCompleted().- Specified by:
onErrorin interfaceFlightProducer.StreamListener<FlightEndpoint>
-
onCompleted
public void onCompleted()Description copied from interface:FlightProducer.StreamListenerIndicate that the transmission is finished.- Specified by:
onCompletedin interfaceFlightProducer.StreamListener<FlightEndpoint>
-