``` rust
use tcpserver::tokio; use tokio::io::AsyncReadExt; use tcpserver::XBWrite; use tcpserver::Builder;
async fn main() { let tcpserver = Builder::new("0.0.0.0:5555") .setconnectevent(|addr| { println!("{:?} connect", addr); true }).setinputevent(async move |mut reader, peer| { let mut buff = [0; 4096]; while let Ok(len) = peer.reader.read(&mut buff).await { if len==0{ break; } println!("{:?}",&buff[..len]); peer.send(buff[..len].to_vec()).await.unwrap(); } println!("{:?} disconnect",peer.addr); }).build().await;
tcpserver.start().await.unwrap();
} ```