From 90d60108c127654faeae8b400f7c95e2c75e7b92 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Mon, 18 Oct 2021 11:10:56 +0200
Subject: [PATCH] aquatic_udp: innetwork, use request_sender.try_send; run
 rustfmt

---
 aquatic_udp/src/lib/network.rs | 10 +++++-----
 aquatic_udp/src/lib/tasks.rs   |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/aquatic_udp/src/lib/network.rs b/aquatic_udp/src/lib/network.rs
index 3daad2e..b2403e2 100644
--- a/aquatic_udp/src/lib/network.rs
+++ b/aquatic_udp/src/lib/network.rs
@@ -201,10 +201,10 @@ fn read_requests(
                                 .access_list
                                 .allows(access_list_mode, &request.info_hash.0)
                             {
-                                if let Err(err) =
-                                    request_sender.send((ConnectedRequest::Announce(request), src))
+                                if let Err(err) = request_sender
+                                    .try_send((ConnectedRequest::Announce(request), src))
                                 {
-                                    ::log::warn!("request_sender.send failed: {:?}", err)
+                                    ::log::warn!("request_sender.try_send failed: {:?}", err)
                                 }
                             } else {
                                 let response = Response::Error(ErrorResponse {
@@ -219,9 +219,9 @@ fn read_requests(
                     Ok(Request::Scrape(request)) => {
                         if connections.contains(request.connection_id, src) {
                             if let Err(err) =
-                                request_sender.send((ConnectedRequest::Scrape(request), src))
+                                request_sender.try_send((ConnectedRequest::Scrape(request), src))
                             {
-                                ::log::warn!("request_sender.send failed: {:?}", err)
+                                ::log::warn!("request_sender.try_send failed: {:?}", err)
                             }
                         }
                     }
diff --git a/aquatic_udp/src/lib/tasks.rs b/aquatic_udp/src/lib/tasks.rs
index 13517c4..54a0ce8 100644
--- a/aquatic_udp/src/lib/tasks.rs
+++ b/aquatic_udp/src/lib/tasks.rs
@@ -1,5 +1,5 @@
-use std::sync::Arc;
 use std::sync::atomic::Ordering;
+use std::sync::Arc;
 
 use histogram::Histogram;