Backpressure and coroutines

[elfogre]

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!

[lowasser]

gRPC for Kotlin exerts backpressure the same way flows in general in Kotlin do: they request elements at the rate the consumer finishes with them. You can add a buffer by just calling the normal Flow.buffer.