Skip to content

Commit

Permalink
more logs
Browse files Browse the repository at this point in the history
  • Loading branch information
jnoorchashm37 committed Aug 20, 2024
1 parent 16ea806 commit 72ad9b9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/clients/ws/single.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ use std::{
use futures::{Future, FutureExt, SinkExt, Stream, StreamExt};
use tokio::net::TcpStream;
use tokio_tungstenite::{tungstenite::Message, MaybeTlsStream, WebSocketStream};
use tracing::{debug, error, trace, warn};
use tracing::{debug, error, info, trace, warn};

use super::WsError;
use crate::{
Expand Down Expand Up @@ -163,7 +163,7 @@ where
} else if let Some(reconnect) = this.reconnect_fut.as_mut() {
match reconnect.poll_unpin(cx) {
Poll::Ready(Ok(new_stream)) => {
error!(target: "cex-exchanges::live-stream", exchange=?T::EXCHANGE, "successfully reconnected to stream");
info!(target: "cex-exchanges::live-stream", exchange=?T::EXCHANGE, "successfully reconnected to stream");
this.stream = Some(Box::pin(new_stream));
this.reconnect_fut = None;
cx.waker().wake_by_ref();
Expand Down

0 comments on commit 72ad9b9

Please sign in to comment.