| 584 | } |
| 585 | |
| 586 | Future<Void> readCommitted(Database cx, |
| 587 | PromiseStream<RCGroup> results, |
| 588 | Reference<FlowLock> lock, |
| 589 | KeyRangeRef range, |
| 590 | std::function<std::pair<uint64_t, uint32_t>(Key key)> groupBy) { |
| 591 | return readCommitted( |
| 592 | cx, results, Void(), lock, range, groupBy, Terminator::True, AccessSystemKeys::True, LockAware::True); |
| 593 | } |
| 594 | |
| 595 | ACTOR Future<int> dumpData(Database cx, |
| 596 | PromiseStream<RCGroup> results, |
no test coverage detected