From f9ed98f10d4dafaf928b0d00e5597a0e0c3e2a85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Tue, 19 Oct 2021 23:09:54 +0200 Subject: [PATCH] aquatic_udp: run rustfmt --- aquatic_udp/src/lib/glommio/common.rs | 13 +++++-------- aquatic_udp/src/lib/glommio/handlers.rs | 1 - 2 files changed, 5 insertions(+), 9 deletions(-) diff --git a/aquatic_udp/src/lib/glommio/common.rs b/aquatic_udp/src/lib/glommio/common.rs index c18ac51..5dd6eeb 100644 --- a/aquatic_udp/src/lib/glommio/common.rs +++ b/aquatic_udp/src/lib/glommio/common.rs @@ -1,18 +1,15 @@ use std::cell::RefCell; use std::rc::Rc; -use futures_lite::{AsyncBufReadExt}; +use futures_lite::AsyncBufReadExt; use glommio::io::{BufferedFile, StreamReaderBuilder}; -use glommio::{prelude::*}; +use glommio::prelude::*; use crate::common::*; use crate::config::Config; -pub async fn update_access_list( - config: Config, - access_list: Rc>, -){ - if config.access_list.mode.is_on(){ +pub async fn update_access_list(config: Config, access_list: Rc>) { + if config.access_list.mode.is_on() { let access_list_file = BufferedFile::open(config.access_list.path).await.unwrap(); let mut reader = StreamReaderBuilder::new(access_list_file).build(); @@ -23,7 +20,7 @@ pub async fn update_access_list( match reader.read_line(&mut buf).await { Ok(_) => { access_list.borrow_mut().insert_from_line(&buf); - }, + } Err(err) => { break; } diff --git a/aquatic_udp/src/lib/glommio/handlers.rs b/aquatic_udp/src/lib/glommio/handlers.rs index 3a308b1..397faf3 100644 --- a/aquatic_udp/src/lib/glommio/handlers.rs +++ b/aquatic_udp/src/lib/glommio/handlers.rs @@ -90,4 +90,3 @@ async fn handle_request_stream( yield_if_needed().await; } } -