google-cloud-rust
google-cloud-rust copied to clipboard
Optimize subscriber lease actions
For example, in LeaseState::shutdown(), we ack messages, and we nack messages. This can take two different RPCs. We should spawn tasks for each of these actions, and await them concurrently.
This also applies to LeaseState::flush(), which should not block the lease event loop.