⬆️ (Cargo.toml): Bump lightstreamer-client version from 0.1.8 to 0.1.9

✨ (Cargo.toml): Add colored dependency to enhance console output
📝 (README.md): Overhaul documentation to provide comprehensive details about the project, its features, usage, and contribution guidelines
💡 (client_listener.rs, client_message_listener.rs): Add newline at end of file to adhere to POSIX standards

♻️ (connection_options.rs): Refactor code to improve readability and maintainability
🐛 (connection_options.rs): Rename 'reduce_head' to '_reduce_head' to indicate unused variable
♻️ (error.rs): Reorder imports and adjust formatting for consistency
♻️ (item_update.rs): Refactor code to improve readability and maintainability
♻️ (lib.rs): Reorder module imports for better organization

♻️ (ls_client.rs): Refactor code to improve readability and maintainability
💡 (main.rs): Update print statements to use colored output for changed fields
🐛 (main.rs): Fix import order to follow Rust's idiomatic style
🐛 (proxy.rs, subscription.rs, subscription_listener.rs): Add newline at end of file to follow POSIX standard
♻️ (subscription.rs, subscription_listener.rs): Refactor code to improve readability and maintainability

📝 (util.rs): Add newline at end of file to adhere to POSIX standards

1 files changed, 3 insertions, 2 deletions

diff --git a/src/ls_client.rs b/src/ls_client.rs
index b65885c..39d7c8b 100644
--- a/src/ls_client.rs
+++ b/src/ls_client.rs
@@ -315,7 +315,8 @@ impl LightstreamerClient {
         let mut request_id: usize = 0;
         let mut _session_id: Option<String> = None;
         let mut subscription_id: usize = 0;
-        let mut subscription_item_updates: HashMap<usize, HashMap<usize, ItemUpdate>> = HashMap::new();
+        let mut subscription_item_updates: HashMap<usize, HashMap<usize, ItemUpdate>> =
+            HashMap::new();
         loop {
             tokio::select! {
                 message = read_stream.next() => {
@@ -488,7 +489,7 @@ impl LightstreamerClient {
                                                                     // is always a snapshot.
                                                                     if let Some(item_updates) = subscription_item_updates.get(&(subscription_index)) {
                                                                         if let Some(_) = item_updates.get(&(item_index)) {
-                                                                            // Item update already exists in item_updates, so it's not a snapshot. 
+                                                                            // Item update already exists in item_updates, so it's not a snapshot.
                                                                             false
                                                                         } else {
                                                                             // Item update doesn't exist in item_updates, so the first update is always a snapshot.