不断接收字节流并打印到stdout
| 6 | |
| 7 | // 不断接收字节流并打印到stdout |
| 8 | task<> recv_session(Socket sock) { |
| 9 | alignas(8192) char buf[8192]; |
| 10 | int nr = co_await sock.recv(buf); |
| 11 | |
| 12 | while (nr > 0) { |
| 13 | nr = co_await ( |
| 14 | lazy::write(STDOUT_FILENO, {buf, (size_t)nr}) && sock.recv(buf) |
| 15 | ); |
| 16 | } |
| 17 | } |
| 18 | |
| 19 | // 将键盘输入发送给对方 |
| 20 | task<> send_session(Socket sock) { |