For the backpressure part you may want to read my explanation in this forum thread: Backpressure support with Akka grpc