| 992 | } |
| 993 | |
| 994 | void stall() { rawQueue->stall(); } |
| 995 | |
| 996 | Future<bool> initializeRecovery(location recoverAt) override { return initializeRecovery(this, recoverAt); } |
| 997 | Future<Standalone<StringRef>> readNext(int bytes) override { return readNext(this, bytes); } |