cargo fmt

src/bin/client.rs

 use std::io;
 use std::sync::{Arc, Mutex};
 
+use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tokio::net::{UnixListener, UnixStream};
 use tokio::stream::StreamExt;
-use tokio::io::{AsyncWriteExt, AsyncReadExt};
 
 use twfss::Database;
 
                     Err(e) => {
                         // Log error and try to send it to the stream.
                         // TODO
-                        stream.write_all(format!("Error: {:?}", e).as_bytes()).await.ok();
+                        stream
+                            .write_all(format!("Error: {:?}", e).as_bytes())
+                            .await
+                            .ok();
                     }
                 };
             }

src/bin/server.rs

+use std::fs::create_dir_all;
 use std::net::SocketAddr;
 use std::sync::{Arc, Mutex};
-use std::fs::create_dir_all;
 
 use async_tungstenite::accept_async;
+use futures::sink::SinkExt;
+use futures_tokio_compat::Compat;
 use log::*;
 use tokio::net::{TcpListener, TcpStream};
 use tokio::stream::StreamExt;
-use futures_tokio_compat::Compat;
-use futures::sink::SinkExt;
 
 use twfss::Database;
 
 // TODO: Robust error handling.
 
 async fn accept_connection(peer: SocketAddr, stream: TcpStream) {
-    let mut ws_stream = accept_async(Compat::new(stream)).await.expect("Failed to accept");
+    let mut ws_stream = accept_async(Compat::new(stream))
+        .await
+        .expect("Failed to accept");
 
     info!("New WebSocket connection from {}.", peer);