diff --git a/src/client/connection.rs b/src/client/connection.rs index 9272179..005d2f1 100644 --- a/src/client/connection.rs +++ b/src/client/connection.rs @@ -5,13 +5,12 @@ use tokio::sync::{oneshot, Mutex}; use tokio_tungstenite::tungstenite::Message; use tracing::debug; +use super::InnerError; use crate::{ requests::{ClientRequest, EventSubscription, Identify}, responses::{Hello, Identified, RequestResponse, ServerMessage, Status}, }; -use super::InnerError; - /// Wrapper for the list of ongoing requests that wait for response. #[derive(Default)] pub(super) struct ReceiverList(Mutex>>); diff --git a/src/client/mod.rs b/src/client/mod.rs index 0867c9a..27d0c02 100644 --- a/src/client/mod.rs +++ b/src/client/mod.rs @@ -218,7 +218,7 @@ impl Client { let handle = tokio::spawn(async move { while let Some(Ok(msg)) = read.next().await { - if let Message::Close(info) = &msg { + if let Message::Close(info) = &msg { if let Some(CloseFrame { reason, .. }) = info { info!(%reason, "connection closed with reason"); }