in cpp/acs_agent_client.cc [107:113]
absl::StatusOr<uint64_t> AcsAgentClient::GetMessagePerMinuteQuota() {
absl::MutexLock lock(&reactor_mtx_);
if (reactor_ == nullptr || stream_state_ != ClientState::kReady) {
return absl::FailedPreconditionError("stream not initialized.");
}
return reactor_->GetMessagesPerMinuteQuota();
}