| 73 | } |
| 74 | |
| 75 | void poll() { |
| 76 | poll_queue::observer_msg m; |
| 77 | while (queue.try_dequeue(m)) |
| 78 | boost::variant2::visit(*this, m); |
| 79 | } |
| 80 | |
| 81 | void operator()(const poll_queue::error_message &msg) const noexcept { conf.on_error(msg.msg, {}); } |
| 82 | void operator()(const poll_queue::warning_message &msg) const noexcept { conf.on_warning(msg.msg, {}); } |
nothing calls this directly
no test coverage detected