Method OpenOutputStream

cpp/src/arrow/filesystem/test_util.cc:202–206

GatedMockFilesystem::~GatedMockFilesystem() = default;

Result<std::shared_ptr<io::OutputStream>> GatedMockFilesystem::OpenOutputStream(
    const std::string& path, const std::shared_ptr<const KeyValueMetadata>& metadata) {
  RETURN_NOT_OK(open_output_sem_.Acquire(1));
  return MockFileSystem::OpenOutputStream(path, metadata);
}

Status GatedMockFilesystem::WaitForOpenOutputStream(uint32_t num_waiters) {
  return open_output_sem_.WaitForWaiters(num_waiters);