chore: fmt

websockets/autobahn/src/main.rs

@@ -1,5 +1,5 @@
 use actix::prelude::*;
-use actix_web::{middleware, web, App, Error, HttpRequest, HttpResponse, HttpServer};
+use actix_web::{App, Error, HttpRequest, HttpResponse, HttpServer, middleware, web};
 use actix_web_actors::ws;
 
 async fn ws_index(r: HttpRequest, stream: web::Payload) -> Result<HttpResponse, Error> {

websockets/chat-actorless/src/main.rs

@@ -5,7 +5,7 @@
 use std::io;
 
 use actix_files::NamedFile;
-use actix_web::{middleware, web, App, Error, HttpRequest, HttpResponse, HttpServer, Responder};
+use actix_web::{App, Error, HttpRequest, HttpResponse, HttpServer, Responder, middleware, web};
 use tokio::{
     task::{spawn, spawn_local},
     try_join,

websockets/chat-actorless/src/server.rs

@@ -4,8 +4,8 @@ use std::{
     collections::{HashMap, HashSet},
     io,
     sync::{
-        atomic::{AtomicUsize, Ordering},
         Arc,
+        atomic::{AtomicUsize, Ordering},
     },
 };
 

websockets/chat-broker/src/main.rs

@@ -1,5 +1,5 @@
 use actix_files::{Files, NamedFile};
-use actix_web::{middleware::Logger, web, App, Error, HttpRequest, HttpServer, Responder};
+use actix_web::{App, Error, HttpRequest, HttpServer, Responder, middleware::Logger, web};
 use actix_web_actors::ws;
 
 mod message;

websockets/chat-tcp/src/client.rs

@@ -16,20 +16,22 @@ async fn main() {
     let mut cmd_rx = UnboundedReceiverStream::new(cmd_rx);
 
     // run blocking terminal input reader on separate thread
-    let input_thread = thread::spawn(move || loop {
-        let mut cmd = String::with_capacity(32);
+    let input_thread = thread::spawn(move || {
+        loop {
+            let mut cmd = String::with_capacity(32);
 
-        if io::stdin().read_line(&mut cmd).is_err() {
-            log::error!("error reading line");
-            return;
+            if io::stdin().read_line(&mut cmd).is_err() {
+                log::error!("error reading line");
+                return;
+            }
+
+            if cmd.trim() == "/exit" {
+                println!("exiting input loop");
+                return;
+            }
+
+            cmd_tx.send(cmd).unwrap();
         }
-
-        if cmd.trim() == "/exit" {
-            println!("exiting input loop");
-            return;
-        }
-
-        cmd_tx.send(cmd).unwrap();
     });
 
     let io = TcpStream::connect(("127.0.0.1", 12345)).await.unwrap();

websockets/chat-tcp/src/main.rs

@@ -2,7 +2,7 @@ use std::time::{Duration, Instant};
 
 use actix::prelude::*;
 use actix_files::NamedFile;
-use actix_web::{middleware::Logger, web, App, Error, HttpRequest, HttpServer, Responder};
+use actix_web::{App, Error, HttpRequest, HttpServer, Responder, middleware::Logger, web};
 use actix_web_actors::ws;
 
 mod codec;

websockets/chat-tcp/src/session.rs

@@ -9,7 +9,7 @@ use std::{
 
 use actix::{prelude::*, spawn};
 use tokio::{
-    io::{split, WriteHalf},
+    io::{WriteHalf, split},
     net::{TcpListener, TcpStream},
 };
 use tokio_util::codec::FramedRead;

websockets/chat/src/main.rs

@@ -1,7 +1,7 @@
 use std::{
     sync::{
-        atomic::{AtomicUsize, Ordering},
         Arc,
+        atomic::{AtomicUsize, Ordering},
     },
     time::Instant,
 };
@@ -9,7 +9,7 @@ use std::{
 use actix::*;
 use actix_files::{Files, NamedFile};
 use actix_web::{
-    middleware::Logger, web, App, Error, HttpRequest, HttpResponse, HttpServer, Responder,
+    App, Error, HttpRequest, HttpResponse, HttpServer, Responder, middleware::Logger, web,
 };
 use actix_web_actors::ws;
 

websockets/chat/src/server.rs

@@ -5,8 +5,8 @@
 use std::{
     collections::{HashMap, HashSet},
     sync::{
-        atomic::{AtomicUsize, Ordering},
         Arc,
+        atomic::{AtomicUsize, Ordering},
     },
 };
 

websockets/echo-actorless/src/client.rs

@@ -18,15 +18,17 @@ async fn main() {
     let mut cmd_rx = UnboundedReceiverStream::new(cmd_rx);
 
     // run blocking terminal input reader on separate thread
-    let input_thread = thread::spawn(move || loop {
-        let mut cmd = String::with_capacity(32);
+    let input_thread = thread::spawn(move || {
+        loop {
+            let mut cmd = String::with_capacity(32);
 
-        if io::stdin().read_line(&mut cmd).is_err() {
-            log::error!("error reading line");
-            return;
+            if io::stdin().read_line(&mut cmd).is_err() {
+                log::error!("error reading line");
+                return;
+            }
+
+            cmd_tx.send(cmd).unwrap();
         }
-
-        cmd_tx.send(cmd).unwrap();
     });
 
     let (res, mut ws) = awc::Client::new()

websockets/echo-actorless/src/handler.rs

@@ -3,8 +3,8 @@ use std::time::{Duration, Instant};
 use actix_web::web;
 use actix_ws::Message;
 use futures_util::{
-    future::{self, Either},
     StreamExt as _,
+    future::{self, Either},
 };
 use tokio::{pin, select, sync::broadcast, time::interval};
 

websockets/echo-actorless/src/main.rs

@@ -6,7 +6,7 @@ use std::io;
 
 use actix_files::NamedFile;
 use actix_web::{
-    middleware, rt, web, App, Error, HttpRequest, HttpResponse, HttpServer, Responder,
+    App, Error, HttpRequest, HttpResponse, HttpServer, Responder, middleware, rt, web,
 };
 use tokio::sync::broadcast;
 

websockets/echo/src/main.rs

@@ -3,7 +3,7 @@
 //! Open `http://localhost:8080/` in browser to test.
 
 use actix_files::NamedFile;
-use actix_web::{middleware, web, App, Error, HttpRequest, HttpResponse, HttpServer, Responder};
+use actix_web::{App, Error, HttpRequest, HttpResponse, HttpServer, Responder, middleware, web};
 use ractor::Actor;
 
 mod server;