Method Push

getting-started/gke/index_gcs.cc:160–166

    : client_(std::move(client)) {}

future<Status> MutationBatcher::Push(gcs::ObjectMetadata const& o) {
  std::unique_lock lk(mu_);
  // Make room for the new data.
  FlushIfNeeded(lk);
  items_.push_back(Item{UpdateObjectMetadata(o), promise<Status>{}});
  return items_.back().done.get_future();
}

std::int64_t MutationBatcher::Flush() {
  std::unique_lock lk(mu_);