| 26 | namespace this_coro = boost::asio::this_coro; |
| 27 | |
| 28 | awaitable<void> echo(tcp_socket socket) |
| 29 | { |
| 30 | try |
| 31 | { |
| 32 | char data[1024]; |
| 33 | for (;;) |
| 34 | { |
| 35 | std::size_t n = co_await socket.async_read_some(boost::asio::buffer(data)); |
| 36 | co_await async_write(socket, boost::asio::buffer(data, n)); |
| 37 | } |
| 38 | } |
| 39 | catch (std::exception& e) |
| 40 | { |
| 41 | std::printf("echo Exception: %s\n", e.what()); |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | awaitable<void> listener() |
| 46 | { |
no test coverage detected