基于队列参与者的异步tcpclient。
例子回声
添加依赖项
[ dependencies ]
tokio = { version = " 0.2 " , features = [ " full " ] }
aqueue = " 0.1.18 "
bytes = " 0.6 "
log = " 0.4 "
env_logger = " 0.8.2 "
主
#![feature(async_closure)]
use tcpclient :: {TcpClient,SocketClientTrait};
use bytes :: {BytesMut, BufMut};
use tokio :: io :: AsyncReadExt;
use std :: error :: Error;
use log :: LevelFilter;
#[tokio::main]
async fn mai
