diff --git a/src/threads/data/websocket.rs b/src/threads/data/websocket.rs index 0ce8cbc..a691eea 100644 --- a/src/threads/data/websocket.rs +++ b/src/threads/data/websocket.rs @@ -9,7 +9,7 @@ use futures_util::{ stream::{SplitSink, SplitStream}, SinkExt, StreamExt, }; -use log::{error, info, warn}; +use log::{debug, error, info, warn}; use serde_json::from_str; use std::{collections::HashSet, sync::Arc}; use tokio::{ @@ -181,7 +181,7 @@ async fn handle_parsed_websocket_message( return; } - info!( + debug!( "{:?} - Received bar for {}: {}.", thread_type, bar.symbol, bar.time ); @@ -203,7 +203,7 @@ async fn handle_parsed_websocket_message( return; } - info!( + debug!( "{:?} - Received news for {:?}: {}.", thread_type, news.symbols, news.time_created );