[ARROW-10106] [FlightRPC][Java] Expose onIsReady() callback on OutboundStreamListener

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.0.0
• Component/s: FlightRPC, Java
• Labels: flight pull-request-available
• External issue URL: https://github.com/apache/arrow/issues/26120
• Assignee: James Duong
• Reporter: James Duong
• Created: 26/Sep/20 09:56
• Updated: 11/Jan/23 08:11
• Resolved: 19/Oct/20 12:42

Description

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.

Issue Links

• links to: GitHub Pull Request #8476