From 3f7dae65a2a40f24a40292d796c142e8e8b00926 Mon Sep 17 00:00:00 2001 From: Ferdinand Schober Date: Thu, 11 Jul 2024 00:51:49 +0200 Subject: [PATCH] fmt --- src/server.rs | 10 ++++------ src/server/frontend_task.rs | 1 - 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/src/server.rs b/src/server.rs index 965a57e..201aabb 100644 --- a/src/server.rs +++ b/src/server.rs @@ -2,7 +2,8 @@ use log; use std::{ cell::{Cell, RefCell}, collections::HashSet, - rc::Rc, sync::Arc, + rc::Rc, + sync::Arc, }; use tokio::{signal, sync::Notify}; use tokio_util::sync::CancellationToken; @@ -124,11 +125,8 @@ impl Server { // create dns resolver let resolver = dns::DnsResolver::new().await?; - let (mut resolver_task, resolve_tx) = resolver_task::new( - resolver, - self.clone(), - frontend_notify_tx, - ); + let (mut resolver_task, resolve_tx) = + resolver_task::new(resolver, self.clone(), frontend_notify_tx); // frontend listener let (mut frontend_task, frontend_tx) = frontend_task::new( diff --git a/src/server/frontend_task.rs b/src/server/frontend_task.rs index b7feb33..8763abf 100644 --- a/src/server/frontend_task.rs +++ b/src/server/frontend_task.rs @@ -79,7 +79,6 @@ fn handle_frontend_stream( #[cfg(windows)] stream: ReadHalf, cancellation_token: CancellationToken, ) -> JoinHandle<()> { - let tx = frontend_tx.clone(); tokio::task::spawn_local(async move { tokio::select! {