From a4c0cb22a94640958878213fc8dcd2fae4868673 Mon Sep 17 00:00:00 2001 From: Rob Ede Date: Sun, 10 Sep 2023 20:22:26 +0100 Subject: [PATCH] chore: fmt --- https-tls/rustls-client-cert/src/main.rs | 2 +- websockets/chat-actorless/src/server.rs | 10 ++-------- websockets/chat/src/server.rs | 10 ++-------- 3 files changed, 5 insertions(+), 17 deletions(-) diff --git a/https-tls/rustls-client-cert/src/main.rs b/https-tls/rustls-client-cert/src/main.rs index 7c6ec3bf..7c074a82 100644 --- a/https-tls/rustls-client-cert/src/main.rs +++ b/https-tls/rustls-client-cert/src/main.rs @@ -1,7 +1,7 @@ //! This example shows how to use `actix_web::HttpServer::on_connect` to access client certificates //! pass them to a handler through connection-local data. -use std::{any::Any, sync::Arc, fs::File, io::BufReader, net::SocketAddr}; +use std::{any::Any, fs::File, io::BufReader, net::SocketAddr, sync::Arc}; use actix_tls::accept::rustls_0_21::{reexports::ServerConfig, TlsStream}; use actix_web::{ diff --git a/websockets/chat-actorless/src/server.rs b/websockets/chat-actorless/src/server.rs index 9d0f273c..bbe0d8b8 100644 --- a/websockets/chat-actorless/src/server.rs +++ b/websockets/chat-actorless/src/server.rs @@ -128,10 +128,7 @@ impl ChatServer { self.sessions.insert(id, tx); // auto join session to main room - self.rooms - .entry("main".to_owned()) - .or_default() - .insert(id); + self.rooms.entry("main".to_owned()).or_default().insert(id); let count = self.visitor_count.fetch_add(1, Ordering::SeqCst); self.send_system_message("main", 0, format!("Total visitors {count}")) @@ -185,10 +182,7 @@ impl ChatServer { .await; } - self.rooms - .entry(room.clone()) - .or_default() - .insert(conn_id); + self.rooms.entry(room.clone()).or_default().insert(conn_id); self.send_system_message(&room, conn_id, "Someone connected") .await; diff --git a/websockets/chat/src/server.rs b/websockets/chat/src/server.rs index df4e73fa..8559859a 100644 --- a/websockets/chat/src/server.rs +++ b/websockets/chat/src/server.rs @@ -129,10 +129,7 @@ impl Handler for ChatServer { self.sessions.insert(id, msg.addr); // auto join session to main room - self.rooms - .entry("main".to_owned()) - .or_default() - .insert(id); + self.rooms.entry("main".to_owned()).or_default().insert(id); let count = self.visitor_count.fetch_add(1, Ordering::SeqCst); self.send_message("main", &format!("Total visitors {count}"), 0); @@ -211,10 +208,7 @@ impl Handler for ChatServer { self.send_message(&room, "Someone disconnected", 0); } - self.rooms - .entry(name.clone()) - .or_default() - .insert(id); + self.rooms.entry(name.clone()).or_default().insert(id); self.send_message(&name, "Someone connected", id); }