soaos/lightstreamer-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

✨ (Cargo.toml): bump version to 0.1.6 for new release

Browse Source 
✨ (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
This commit is contained in:
Daniel López Azaña 2024-04-07 20:32:51 +02:00
parent 01b70468fc
commit 2a68c66704
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Cargo.toml
View File

@ -1,6 +1,6 @@
[package] [package]
name = "lightstreamer-client" name = "lightstreamer-client"
version = "0.1.5" version = "0.1.6"
edition = "2021" edition = "2021"
authors = ["Daniel López Azaña <daniloaz@gmail.com>"] authors = ["Daniel López Azaña <daniloaz@gmail.com>"]
description = "A Rust client for Lightstreamer, designed to facilitate real-time communication with Lightstreamer servers." description = "A Rust client for Lightstreamer, designed to facilitate real-time communication with Lightstreamer servers."

5
src/ls_client.rs
View File

@ -443,6 +443,7 @@ impl LightstreamerClient {
// Prepare the subscription request. // Prepare the subscription request.
// //
let mut params: Vec<(&str, &str)> = vec![ let mut params: Vec<(&str, &str)> = vec![
("LS_data_adapter", &ls_data_adapter),
("LS_reqId", &ls_req_id), ("LS_reqId", &ls_req_id),
("LS_op", "add"), ("LS_op", "add"),
("LS_subId", &ls_sub_id), ("LS_subId", &ls_sub_id),
@ -451,6 +452,10 @@ impl LightstreamerClient {
("LS_schema", &ls_schema), ("LS_schema", &ls_schema),
("LS_ack", "false"), ("LS_ack", "false"),
]; ];
// Remove the data adapter parameter if not specified.
if ls_data_adapter == "" {
params.remove(0);
}
if ls_snapshot != "" { if ls_snapshot != "" {
params.push(("LS_snapshot", &ls_snapshot)); params.push(("LS_snapshot", &ls_snapshot));
} }