Before calling push, pop, or commit, the user must call readNext() until it throws end_of_stream(). It may not be called again thereafter.
| 117 | // Before calling push, pop, or commit, the user must call readNext() until it throws |
| 118 | // end_of_stream(). It may not be called again thereafter. |
| 119 | Future<TLogQueueEntry> readNext(TLogData* tLog) { return readNext(this, tLog); } |
| 120 | |
| 121 | Future<bool> initializeRecovery(IDiskQueue::location recoverAt) { return queue->initializeRecovery(recoverAt); } |
| 122 |
no test coverage detected