| 3031 | } |
| 3032 | |
| 3033 | Future<std::vector<std::string>> ListBucketsAsync() { |
| 3034 | auto deferred = |
| 3035 | [self = shared_from_this()]() mutable -> Result<std::vector<std::string>> { |
| 3036 | ARROW_ASSIGN_OR_RAISE(auto client_lock, self->holder_->Lock()); |
| 3037 | return self->ProcessListBuckets(client_lock.Move()->ListBuckets()); |
| 3038 | }; |
| 3039 | return DeferNotOk(SubmitIO(io_context_, std::move(deferred))); |
| 3040 | } |
| 3041 | |
| 3042 | Result<std::shared_ptr<ObjectInputFile>> OpenInputFile(const std::string& s, |
| 3043 | S3FileSystem* fs) { |
nothing calls this directly
no test coverage detected