James Duong created ARROW-10106: ----------------------------------- Summary: [FlightRPC][Java] Expose onIsReady() callback on OutboundStreamListener Key: ARROW-10106 URL: https://issues.apache.org/jira/browse/ARROW-10106 Project: Apache Arrow Issue Type: Improvement Components: FlightRPC, Java Reporter: James Duong
OutboundStreamListener has a method isReady() that FlightProducers need to poll during implementations of getStream() to avoid buffering too much data. An enhancement would be to allow setting a callback to run (for example, notifying a CountdownLatch) so that FlightProducer implementations don't need to busy wait. -- This message was sent by Atlassian Jira (v8.3.4#803005)