| 185 | } |
| 186 | |
| 187 | void deliver(const std::string& msg) override |
| 188 | { |
| 189 | output_queue_.push_back(msg + "\n"); |
| 190 | |
| 191 | // Signal that the output queue contains messages. Modifying the expiry |
| 192 | // will wake the output actor, if it is waiting on the timer. |
| 193 | non_empty_output_queue_.expires_at(steady_timer::time_point::min()); |
| 194 | } |
| 195 | |
| 196 | void read_line() |
| 197 | { |
nothing calls this directly
no test coverage detected