After digging a little, it seems there is support for "flow control", although I can't seem to find any examples of how to do this. I've seen references to ClientResponseObserver, but not finding any way to integrate this either. Any pointers on how to work with gRPC's flow control - more importantly, am I on the right track here?
- Matt I just need to make sure that if the client isn't consuming quickly enough, that the server doesn't continue to push data into its buffer and then run out of memory. On Saturday, October 22, 2016 at 5:41:04 PM UTC-4, good...@gmail.com wrote: > > Hi, > > I'm messing around with a Java server/client impl with grpc and would like > to have the Server stream back chunks from an InputStream. The chunking > using a bytes type seems fine, but now I'm wondering if there's a way to do > some sort of blocking-queue, so that if the client slows down reading, the > server will slow down too (I'm getting "java.lang.OutOfMemoryError: Direct > buffer memory" in the server) -- Is this possible? > > Thanks! > -- You received this message because you are subscribed to the Google Groups "grpc.io" group. To unsubscribe from this group and stop receiving emails from it, send an email to grpc-io+unsubscr...@googlegroups.com. To post to this group, send email to grpc-io@googlegroups.com. Visit this group at https://groups.google.com/group/grpc-io. To view this discussion on the web visit https://groups.google.com/d/msgid/grpc-io/e8bdb2ca-6712-4d7a-afe8-01685dd5c326%40googlegroups.com. For more options, visit https://groups.google.com/d/optout.
