diff --git a/src/https.rs b/src/https.rs
index ce9c61f..6e83c9e 100644
--- a/src/https.rs
+++ b/src/https.rs
@@ -213,7 +213,7 @@ async fn select_target_and_proxy(
 	let host = if let Some(auth) = req.uri().authority() {
 		auth.as_str()
 	} else {
-		match req.headers().get("host").map(|x| x.to_str().ok()).flatten() {
+		match req.headers().get("host").and_then(|x| x.to_str().ok()) {
 			Some(host) => host,
 			None => {
 				return Response::builder()
@@ -268,7 +268,7 @@ async fn select_target_and_proxy(
 		debug!("{}{} -> {}", host, path, proxy_to);
 		trace!("Request: {:?}", req);
 
-		let response = match do_proxy(&https_config, remote_addr, req, proxy_to).await {
+		let response = match do_proxy(https_config, remote_addr, req, proxy_to).await {
 			Ok(resp) => resp,
 			Err(e) => Response::builder()
 				.status(StatusCode::BAD_GATEWAY)
@@ -279,7 +279,7 @@ async fn select_target_and_proxy(
 		proxy_to.calls_in_progress.fetch_sub(1, Ordering::SeqCst);
 		metrics
 			.request_proxy_duration
-			.record(received_time.elapsed().as_secs_f64(), &tags);
+			.record(received_time.elapsed().as_secs_f64(), tags);
 
 		trace!("Final response: {:?}", response);
 		info!("{} {} {}", method, response.status().as_u16(), uri);
@@ -323,7 +323,7 @@ async fn do_proxy(
 	}
 
 	if https_config.enable_compression {
-		response = try_compress(response, method, accept_encoding, &https_config).await?
+		response = try_compress(response, method, accept_encoding, https_config).await?
 	};
 
 	Ok(response)
diff --git a/src/main.rs b/src/main.rs
index 34c80f8..79c4a9b 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -192,10 +192,10 @@ async fn main() {
 
 	let dump_task = tokio::spawn(dump_config_on_change(rx_proxy_config, exit_signal.clone()));
 
-	let _ = metrics_task.await.expect("Tokio task await failure");
-	let _ = http_task.await.expect("Tokio task await failure");
-	let _ = https_task.await.expect("Tokio task await failure");
-	let _ = dump_task.await.expect("Tokio task await failure");
+	metrics_task.await.expect("Tokio task await failure");
+	http_task.await.expect("Tokio task await failure");
+	https_task.await.expect("Tokio task await failure");
+	dump_task.await.expect("Tokio task await failure");
 }
 
 async fn dump_config_on_change(
@@ -205,7 +205,7 @@ async fn dump_config_on_change(
 	while !*must_exit.borrow() {
 		select!(
 			c = rx_proxy_config.changed() => {
-				if !c.is_ok() {
+				if c.is_err() {
 					break;
 				}
 			}
diff --git a/src/reverse_proxy.rs b/src/reverse_proxy.rs
index 74c43e3..258862b 100644
--- a/src/reverse_proxy.rs
+++ b/src/reverse_proxy.rs
@@ -178,7 +178,7 @@ async fn create_proxied_response<B: std::default::Default + Send + Sync + 'stati
 			*new_res.headers_mut().unwrap() = new_headers;
 			Ok(new_res.body(B::default())?)
 		} else {
-			return Err(anyhow!("Switching protocols but not an upgrade request"));
+			Err(anyhow!("Switching protocols but not an upgrade request"))
 		}
 	} else {
 		*response.headers_mut() = new_headers;