Uses of Interface
org.apache.arrow.flight.FlightProducer.ServerStreamListener

Packages that use FlightProducer.ServerStreamListener

Package	Description
org.apache.arrow.flight
org.apache.arrow.flight.example

Uses of FlightProducer.ServerStreamListener in org.apache.arrow.flight

Methods in org.apache.arrow.flight with parameters of type FlightProducer.ServerStreamListener

Modifier and Type	Method and Description
default void	FlightProducer.doExchange(FlightProducer.CallContext context, FlightStream reader, FlightProducer.ServerStreamListener writer)
void	FlightProducer.getStream(FlightProducer.CallContext context, Ticket ticket, FlightProducer.ServerStreamListener listener) Return data for a stream.
void	NoOpFlightProducer.getStream(FlightProducer.CallContext context, Ticket ticket, FlightProducer.ServerStreamListener listener)
void	BackpressureStrategy.register(FlightProducer.ServerStreamListener listener) Set up operations to work against the given listener.
void	BackpressureStrategy.CallbackBackpressureStrategy.register(FlightProducer.ServerStreamListener listener)
protected boolean	BackpressureStrategy.CallbackBackpressureStrategy.shouldContinueWaiting(FlightProducer.ServerStreamListener listener, long remainingTimeout) Callback function to run to check if the listener should continue to be waited on if it leaves the waiting state without being cancelled, ready, or timed out.

Uses of FlightProducer.ServerStreamListener in org.apache.arrow.flight.example

Methods in org.apache.arrow.flight.example with parameters of type FlightProducer.ServerStreamListener

Modifier and Type	Method and Description
void	InMemoryStore.getStream(FlightProducer.CallContext context, Ticket ticket, FlightProducer.ServerStreamListener listener)
void	Stream.sendTo(BufferAllocator allocator, FlightProducer.ServerStreamListener listener) Sends that data from this object to the given listener.