| 377 | |
| 378 | |
| 379 | Future<Log::Position> LogReaderProcess::_ending() |
| 380 | { |
| 381 | CHECK_READY(recovering); |
| 382 | |
| 383 | return recovering.get()->ending() |
| 384 | .then(lambda::bind(&Self::position, lambda::_1)); |
| 385 | } |
| 386 | |
| 387 | |
| 388 | Future<list<Log::Entry>> LogReaderProcess::read( |