grpc-java
grpc-java copied to clipboard
binder: CallStreamObserver request()s are not reflected by isReady() at the peer
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.
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.