grpc-java icon indicating copy to clipboard operation
grpc-java copied to clipboard

binder: CallStreamObserver request()s are not reflected by isReady() at the peer

Open jdcormie opened this issue 2 years ago • 1 comments

Is your feature request related to a problem?

Yes, lack of message-by-message stream flow control

Describe the solution you'd like

The binder transport should implement the isReady() and request() methods of CallStreamObserver to behave as documented.

Describe alternatives you've considered

Today, system designers needing flow control must include tokens / acks in their API as explicit messages.

jdcormie avatar Mar 22 '22 21:03 jdcormie

For those not in-the-loop: the binder protocol itself doesn't support per-stream flow control. We'll need to enhance the wire protocol.

ejona86 avatar Mar 22 '22 22:03 ejona86