grpc-kotlin
grpc-kotlin copied to clipboard
Backpressure and coroutines
trafficstars
Hi!
I found some references about backpressure and rxjava on other implementations: https://github.com/salesforce/reactive-grpc#back-pressure
I was reading all your doc but I can not found if grpc-kotlin lib has a backpressure implementation that could block the suspendable flow.emit() function.
Also if that is working, how could I configure buffer sizes?
Thanks in advance!