| 91 | } |
| 92 | |
| 93 | void ReadBuffer::cancel() |
| 94 | { |
| 95 | if (std::current_exception()) |
| 96 | tryLogCurrentException(getLogger("ReadBuffer"), "ReadBuffer is canceled by the exception", LogsLevel::debug); |
| 97 | else |
| 98 | LOG_DEBUG(getLogger("ReadBuffer"), "ReadBuffer is canceled at {}", StackTrace().toString()); |
| 99 | |
| 100 | canceled = true; |
| 101 | } |
| 102 | |
| 103 | bool ReadBuffer::next() |
| 104 | { |
no test coverage detected