loop {
let peer_mgr = peer_manager_connection_handler.clone();
let notifier = event_notifier.clone();
let tcp_stream = listener.accept().await.unwrap().0;
tokio::spawn(async move {
loop {
let peer_mgr = peer_manager_connection_handler.clone();
let notifier = event_notifier.clone();
let tcp_stream = listener.accept().await.unwrap().0;
tokio::spawn(async move {