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

How to provide backpressure when using ApiStreamObserver?

Open meltsufin opened this issue 6 years ago • 2 comments

You can use the async GRPC client stub and pass in a ClientResponseObserver in place of the StreamObserver, which has an additional method called beforeStart that provides a ClientCallStreamObserver that has the request(count) method. However, I cannot find a similar request(count) method in ApiStreamObserver to provide backpressure.

meltsufin avatar Aug 12 '19 21:08 meltsufin

@vam-google @hzyi-google please triage or redirect.

software-dov avatar Aug 19 '19 20:08 software-dov

Please bump if necessary.

yihanzhen avatar Aug 19 '19 21:08 yihanzhen