async fn serve_consensus_connection( conn: TcpStream, state: ConsensusState, ) -> Result<(), ExternalError>