| 171 | void executeMessages() noexcept; |
| 172 | Message *readMessage() noexcept; |
| 173 | inline bool hasNewMessage() const noexcept { return _reader.newMessageCount > 0 && !_reader.flushingFinished; } |
| 174 | void consumerThreadLoop() noexcept; |
| 175 | |
| 176 | WriterContext _writer; |