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