Lower incoming data log level
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
@@ -9,7 +9,7 @@ use futures_util::{
|
|||||||
stream::{SplitSink, SplitStream},
|
stream::{SplitSink, SplitStream},
|
||||||
SinkExt, StreamExt,
|
SinkExt, StreamExt,
|
||||||
};
|
};
|
||||||
use log::{error, info, warn};
|
use log::{debug, error, info, warn};
|
||||||
use serde_json::from_str;
|
use serde_json::from_str;
|
||||||
use std::{collections::HashSet, sync::Arc};
|
use std::{collections::HashSet, sync::Arc};
|
||||||
use tokio::{
|
use tokio::{
|
||||||
@@ -181,7 +181,7 @@ async fn handle_parsed_websocket_message(
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
info!(
|
debug!(
|
||||||
"{:?} - Received bar for {}: {}.",
|
"{:?} - Received bar for {}: {}.",
|
||||||
thread_type, bar.symbol, bar.time
|
thread_type, bar.symbol, bar.time
|
||||||
);
|
);
|
||||||
@@ -203,7 +203,7 @@ async fn handle_parsed_websocket_message(
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
info!(
|
debug!(
|
||||||
"{:?} - Received news for {:?}: {}.",
|
"{:?} - Received news for {:?}: {}.",
|
||||||
thread_type, news.symbols, news.time_created
|
thread_type, news.symbols, news.time_created
|
||||||
);
|
);
|
||||||
|
Reference in New Issue
Block a user