| 2972 | } |
| 2973 | |
| 2974 | Future<std::vector<std::string>> ListBucketsAsync() { |
| 2975 | auto deferred = |
| 2976 | [self = shared_from_this()]() mutable -> Result<std::vector<std::string>> { |
| 2977 | ARROW_ASSIGN_OR_RAISE(auto client_lock, self->holder_->Lock()); |
| 2978 | return self->ProcessListBuckets(client_lock.Move()->ListBuckets()); |
| 2979 | }; |
| 2980 | return DeferNotOk(SubmitIO(io_context_, std::move(deferred))); |
| 2981 | } |
| 2982 | |
| 2983 | Result<std::shared_ptr<ObjectInputFile>> OpenInputFile(const std::string& s, |
| 2984 | S3FileSystem* fs) { |
nothing calls this directly
no test coverage detected