MCPcopy Create free account
hub / github.com/apache/arrow / DeliverBatches

Method DeliverBatches

cpp/src/arrow/dataset/scanner_test.cc:202–211  ·  view source on GitHub ↗

### Unit Test API ###

Source from the content-addressed store, hash-verified

200
201 // ### Unit Test API ###
202 void DeliverBatches(bool slow, const std::vector<MockScanTask>& to_deliver) {
203 for (MockScanTask task : to_deliver) {
204 if (slow) {
205 std::ignore = SleepABitAsync().Then(
206 [task]() mutable { task.batch_future.MarkFinished(task.batch); });
207 } else {
208 task.batch_future.MarkFinished(task.batch);
209 }
210 }
211 }
212
213 void DeliverBatchesInOrder(bool slow) { DeliverBatches(slow, scan_tasks_); }
214

Callers

nothing calls this directly

Calls 3

SleepABitAsyncFunction · 0.85
ThenMethod · 0.80
MarkFinishedMethod · 0.45

Tested by

no test coverage detected