Run cargo fmt

aquatic_http/src/lib.rs

@@ -15,8 +15,8 @@ use std::{
 use crate::config::Config;
 
 mod common;
-mod workers;
 pub mod config;
+mod workers;
 
 pub const APP_NAME: &str = "aquatic_http: HTTP/TLS BitTorrent tracker";
 
@@ -115,8 +115,13 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> {
                 WorkerIndex::RequestWorker(i),
             );
 
-            workers::request::run_request_worker(config, state, request_mesh_builder, response_mesh_builder)
+            workers::request::run_request_worker(
-                .await
+                config,
+                state,
+                request_mesh_builder,
+                response_mesh_builder,
+            )
+            .await
         });
 
         executors.push(executor);

aquatic_http/src/workers/mod.rs

@@ -1,2 +1,2 @@
 pub mod request;
-pub mod socket;
+pub mod socket;

aquatic_udp/src/common.rs

@@ -89,7 +89,7 @@ impl ConnectedRequestSender {
         addr: SocketAddr,
     ) {
         match self.senders[index.0].try_send((self.index, request, addr)) {
-            Ok(()) => {},
+            Ok(()) => {}
             Err(TrySendError::Full(_)) => {
                 ::log::error!("Request channel {} is full, dropping request. Try increasing number of request workers or raising config.worker_channel_size.", index.0)
             }
@@ -116,7 +116,7 @@ impl ConnectedResponseSender {
         addr: SocketAddr,
     ) {
         match self.senders[index.0].try_send((response, addr)) {
-            Ok(()) => {},
+            Ok(()) => {}
             Err(TrySendError::Full(_)) => {
                 ::log::error!("Response channel {} is full, dropping response. Try increasing number of socket workers or raising config.worker_channel_size.", index.0)
             }