Method FlushAsync

cpp/src/arrow/filesystem/azurefs.cc:1203–1222

  }

  Future<> FlushAsync() {
    RETURN_NOT_OK(CheckClosed("flush async"));
    if (!initialised_) {
      // If the stream has not been successfully initialized then there is nothing to
      // flush. This also avoids some unhandled errors when flushing in the destructor.
      return Status::OK();
    }

    Future<> pending_blocks_completed;
    {
      std::unique_lock<std::mutex> lock(upload_state_->mutex);
      pending_blocks_completed = upload_state_->pending_blocks_completed;
    }

    return pending_blocks_completed.Then([self = Self()] {
      std::unique_lock<std::mutex> lock(self->upload_state_->mutex);
      return CommitBlockList(self->block_blob_client_, self->upload_state_->block_ids,
                             self->commit_block_list_options_);
    });
  }

 private:
  Status AppendCurrentBlock() {