| 115 | |
| 116 | private: |
| 117 | awaitable<void> reader() |
| 118 | { |
| 119 | try |
| 120 | { |
| 121 | for (std::string read_msg;;) |
| 122 | { |
| 123 | std::size_t n = co_await boost::asio::async_read_until(socket_, |
| 124 | boost::asio::dynamic_buffer(read_msg, 1024), "\n", use_awaitable); |
| 125 | |
| 126 | room_.deliver(read_msg.substr(0, n)); |
| 127 | read_msg.erase(0, n); |
| 128 | } |
| 129 | } |
| 130 | catch (std::exception&) |
| 131 | { |
| 132 | stop(); |
| 133 | } |
| 134 | } |
| 135 | |
| 136 | awaitable<void> writer() |
| 137 | { |
no test coverage detected