| 255 | } |
| 256 | |
| 257 | static inline arrow::Status SafeCallIntoRVoid(std::function<void(void)> fun, |
| 258 | std::string reason = "unspecified") { |
| 259 | arrow::Future<bool> future = SafeCallIntoRAsync<bool>( |
| 260 | [&fun]() { |
| 261 | fun(); |
| 262 | return true; |
| 263 | }, |
| 264 | reason); |
| 265 | return future.status(); |
| 266 | } |
| 267 | |
| 268 | // Performs an Arrow call (e.g., run an exec plan) in such a way that background threads |
| 269 | // can use SafeCallIntoR(). This version is useful for Arrow calls that already |
no test coverage detected