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; } } -