pub async fn start_listening(stream: TcpStream, addr: SocketAddr)
Starts listening for messages from a new peer