31     pub async fn register(&self, conn: Arc<dyn Conn + Send + Sync>) {  in register()
32         println!("Connected to {}", conn.remote_addr().unwrap());  in register()
34         if let Some(remote_addr) = conn.remote_addr() {  in register()
36             conns.insert(remote_addr.to_string(), Arc::clone(&conn));  in register()
41             let _ = Hub::read_loop(conns, conn).await;  in register()
47         conn: Arc<dyn Conn + Send + Sync>,  in read_loop()
51         while let Ok(n) = conn.recv(&mut b).await {  in read_loop()
56         Hub::unregister(conns, conn).await  in read_loop()
61         conn: Arc<dyn Conn + Send + Sync>,  in unregister()
63         if let Some(remote_addr) = conn.remote_addr() {  in unregister()
69             if let Err(err) = conn.close().await {  in unregister()
81         for conn in conns.values() {  in broadcast()
82             if let Err(err) = conn.send(msg).await {  in broadcast()
85                     conn.remote_addr(),  in broadcast()