✨ (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

2 files changed, 6 insertions, 1 deletions

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 <daniloaz@gmail.com>"]
 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));
                                                 }