Added minor versions to dependencies to avoid breaking changes, fixed some type mismatch errors

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "lightstreamer-client"
-version = "0.1.9"
+version = "0.1.10"
 edition = "2021"
 authors = ["Daniel López Azaña <daniloaz@gmail.com>"]
 description = "A Rust client for Lightstreamer, designed to facilitate real-time communication with Lightstreamer servers."
@@ -11,18 +11,18 @@ documentation = "https://github.com/daniloaz/lightstreamer-client#readme"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-colored = "2"
-cookie = { version = "0", features = ["percent-encode"]}
-futures = "0"
-futures-util = "0"
-json-patch = "1"
-reqwest = { version = "0", features = ["json", "stream"] }
-serde = { version = "1", features = ["derive"] }
-serde_json = { version = "1" }
-serde_urlencoded = "0"
-signal-hook = "0"
-tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
-tokio-tungstenite = { version = "0", features = ["native-tls"] }
-tracing = "0.1.40"
-tracing-subscriber = "0.3.18"
-url = "2"
+colored = "2.2"
+cookie = { version = "0.18", features = ["percent-encode"]}
+futures = "0.3"
+futures-util = "0.3"
+json-patch = "3.0"
+reqwest = { version = "0.12", features = ["json", "stream"] }
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+serde_urlencoded = "0.7"
+signal-hook = "0.3"
+tokio = { version = "1.42", features = ["macros", "rt-multi-thread"] }
+tokio-tungstenite = { version = "0.26", features = ["native-tls"] }
+tracing = "0.1"
+tracing-subscriber = "0.3"
+url = "2.5"

src/error.rs

@@ -1,6 +1,5 @@
 use std::error::Error;
 use std::fmt;
-use tracing::error;
 
 #[derive(Debug)]
 pub struct IllegalArgumentException(String);

src/ls_client.rs

@@ -424,7 +424,7 @@ impl LightstreamerClient {
                                                 }
                                                 let encoded_params = serde_urlencoded::to_string(&params)?;
                                                 write_stream
-                                                    .send(Message::Text(format!("control\r\n{}", encoded_params)))
+                                                    .send(Message::Text(format!("control\r\n{}", encoded_params).into()))
                                                     .await?;
                                                 info!("Sent subscription request: '{}'", encoded_params);
                                             }
@@ -712,7 +712,7 @@ impl LightstreamerClient {
                                         params.push(("LS_protocol", Self::TLCP_VERSION));
                                         let encoded_params = serde_urlencoded::to_string(&params)?;
                                         write_stream
-                                            .send(Message::Text(format!("create_session\r\n{}\n", encoded_params)))
+                                            .send(Message::Text(format!("create_session\r\n{}\n", encoded_params).into()))
                                             .await?;
                                         self.make_log( Level::DEBUG, &format!("Sent create session request: '{}'", encoded_params) );
                                     },

src/main.rs

@@ -63,7 +63,7 @@ impl SubscriptionListener for MySubscriptionListener {
         ];
         let mut output = String::new();
         for field in fields {
-            let value = update.get_value(field).unwrap_or(&not_available).clone();
+            let value = update.get_value(field).unwrap_or(&not_available);
             let value_str = if update.changed_fields.contains_key(field) {
                 value.yellow().to_string()
             } else {