将键盘输入发送给对方
| 18 | |
| 19 | // 将键盘输入发送给对方 |
| 20 | task<> send_session(Socket sock) { |
| 21 | alignas(8192) char buf[8192]; |
| 22 | int nr = co_await lazy::read(STDIN_FILENO, buf); |
| 23 | |
| 24 | while (nr > 0) { |
| 25 | nr = co_await ( |
| 26 | sock.send({buf, (size_t)nr}) && lazy::read(STDIN_FILENO, buf) |
| 27 | ); |
| 28 | } |
| 29 | } |
| 30 | |
| 31 | task<> server(uint16_t port) { |
| 32 | acceptor ac{inet_address{port}}; |