#[tokio::main]
async fn main(){
let listener = TcpListener::bind("127.0.0.1:7878").await.unwrap();
while let Ok((stream, _address)) = listener.accept().await {
// println!("{}", address.to_string());
// Arc::clone(&postgres);
handle_connection(stream).await;
}
async fn handle_connection(mut stream: TcpStream) {
let mut req = accept_async(stream).await.unwrap();
// println!("{:?}", &req.get_config());
println!("{:?}", &req.get_mut());
println!("{:?}", &req.get_ref());
if let Some(msg) = recv.next().await {
// println!("{:?}", msg);
if let Ok(msg) = msg {
let msg = msg.to_text();
if let Ok(msg) = msg {
println!("{}", msg)
}
}
}
}