| 2056 | state std::vector<Future<Void>> rc; |
| 2057 | |
| 2058 | for (auto& range : ranges) { |
| 2059 | rc.push_back( |
| 2060 | readCommitted(cx, results, lock, range, Terminator::False, AccessSystemKeys::True, LockAware::True)); |
| 2061 | } |
| 2062 | |
| 2063 | state Future<Void> sendEOS = map(errorOr(waitForAll(rc)), [=](ErrorOr<Void> const& result) { |
| 2064 | if (result.isError()) |
nothing calls this directly
no test coverage detected