| 1109 | const std::string file_path = dir_path + "/" + file_name; |
| 1110 | expected_infos.emplace_back(file_path, FileType::File); |
| 1111 | ASSERT_OK_AND_ASSIGN(Future<> task, |
| 1112 | ::arrow::internal::GetCpuThreadPool()->Submit( |
| 1113 | [fs = fs_, file_name, file_path]() -> Status { |
| 1114 | ARROW_ASSIGN_OR_RAISE( |
| 1115 | std::shared_ptr<io::OutputStream> out_str, |
| 1116 | fs->OpenOutputStream(file_path)); |
| 1117 | ARROW_RETURN_NOT_OK(out_str->Write(file_name)); |
| 1118 | return out_str->Close(); |
| 1119 | })); |
| 1120 | tasks.push_back(std::move(task)); |
| 1121 | } |
| 1122 | ASSERT_FINISHES_OK(AllFinished(tasks)); |
no test coverage detected