From 65282048aefecda06f937ed670755b64b19ce9b1 Mon Sep 17 00:00:00 2001 From: daniloaz Date: Sat, 13 Apr 2024 21:24:12 +0200 Subject: ⬆️ (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 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit ♻️ (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 --- src/ls_client.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'src/ls_client.rs') 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 = None; let mut subscription_id: usize = 0; - let mut subscription_item_updates: HashMap> = HashMap::new(); + let mut subscription_item_updates: HashMap> = + 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. -- cgit v1.2.3