From 2a68c66704798bf956ac132ab8309212af7fd1c4 Mon Sep 17 00:00:00 2001 From: Daniel López Azaña Date: Sun, 7 Apr 2024 20:32:51 +0200 Subject: ✨ (Cargo.toml): bump version to 0.1.6 for new release ✨ (ls_client.rs): add LS_data_adapter parameter to subscription request ♻️ (ls_client.rs): conditionally remove LS_data_adapter if empty to clean up request params MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Cargo.toml | 2 +- src/ls_client.rs | 5 +++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 8e076aa..55aad92 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "lightstreamer-client" -version = "0.1.5" +version = "0.1.6" edition = "2021" authors = ["Daniel López Azaña "] description = "A Rust client for Lightstreamer, designed to facilitate real-time communication with Lightstreamer servers." diff --git a/src/ls_client.rs b/src/ls_client.rs index 95cdfba..cfd365f 100644 --- a/src/ls_client.rs +++ b/src/ls_client.rs @@ -443,6 +443,7 @@ impl LightstreamerClient { // Prepare the subscription request. // let mut params: Vec<(&str, &str)> = vec![ + ("LS_data_adapter", &ls_data_adapter), ("LS_reqId", &ls_req_id), ("LS_op", "add"), ("LS_subId", &ls_sub_id), @@ -451,6 +452,10 @@ impl LightstreamerClient { ("LS_schema", &ls_schema), ("LS_ack", "false"), ]; + // Remove the data adapter parameter if not specified. + if ls_data_adapter == "" { + params.remove(0); + } if ls_snapshot != "" { params.push(("LS_snapshot", &ls_snapshot)); } -- cgit v1.2.3