diff options
| author |  Alina Hagan <alina-hagan@outlook.com> | 2024-08-10 00:10:15 +0100 |
|---|---|---|
| committer | Alina Hagan <alina-hagan@outlook.com> | 2024-08-10 00:10:15 +0100 |
| commit | d186099afede52316789502ee9bb8b14db5dd914 (patch) | |
| tree | 937df65d06e55f8508e0ef9636964a6e0d417de0 | |
| parent | 4a1625a311b9b2355a82ce3a595c2c4466ed7fcf (diff) | |
Some tuning, cleaned up extraneous error! macros, some INFO's downgraded to DEBUG's
| -rw-r--r-- | src/error.rs | 2 | ||||
| -rw-r--r-- | src/ls_client.rs | 12 |
2 files changed, 6 insertions, 8 deletions
diff --git a/src/error.rs b/src/error.rs index fdec096..0888818 100644 --- a/src/error.rs +++ b/src/error.rs @@ -7,7 +7,6 @@ pub struct IllegalArgumentException(String); impl IllegalArgumentException { pub fn new(msg: &str) -> IllegalArgumentException { - error!(msg); IllegalArgumentException(msg.to_string()) } } @@ -31,7 +30,6 @@ pub struct IllegalStateException { impl IllegalStateException { pub fn new(msg: &str) -> IllegalStateException { - error!(msg); IllegalStateException { details: msg.to_string(), } diff --git a/src/ls_client.rs b/src/ls_client.rs index a496743..f4f72db 100644 --- a/src/ls_client.rs +++ b/src/ls_client.rs @@ -355,8 +355,8 @@ impl LightstreamerClient { // "conok" => { if let Some(session_id) = submessage_fields.get(1).as_deref() { - self.make_log( Level::INFO, &format!("Session creation confirmed by server: {}", clean_text) ); - self.make_log( Level::INFO, &format!("Session created with ID: {:?}", session_id) ); + self.make_log( Level::DEBUG, &format!("Session creation confirmed by server: {}", clean_text) ); + self.make_log( Level::DEBUG, &format!("Session created with ID: {:?}", session_id) ); // // Subscribe to the desired items. // @@ -443,10 +443,10 @@ impl LightstreamerClient { // Don't do anything with these notifications for now. }, "probe" => { - self.make_log( Level::INFO, &format!("Received probe message from server: {}", clean_text ) ); + self.make_log( Level::DEBUG, &format!("Received probe message from server: {}", clean_text ) ); }, "reqok" => { - self.make_log( Level::INFO, &format!("Received reqok message from server: '{}'", clean_text ) ); + self.make_log( Level::DEBUG, &format!("Received reqok message from server: '{}'", clean_text ) ); }, // // Subscription confirmation from server. @@ -714,7 +714,7 @@ impl LightstreamerClient { write_stream .send(Message::Text(format!("create_session\r\n{}\n", encoded_params))) .await?; - self.make_log( Level::INFO, &format!("Sent create session request: '{}'", encoded_params) ); + self.make_log( Level::DEBUG, &format!("Sent create session request: '{}'", encoded_params) ); }, unexpected_message => { return Err(Box::new(std::io::Error::new( @@ -744,7 +744,7 @@ impl LightstreamerClient { ))); }, None => { - self.make_log( Level::INFO, "No more messages from server" ); + self.make_log( Level::DEBUG, "No more messages from server" ); break; }, } |