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

♻️ (ls_client.rs): refactor connect method to check server_address before connecting

Browse Source 
✨ (main.rs): rename subscription to my_subscription for clarity
✨ (main.rs): move subscription setup before client creation
✨ (main.rs): add client.subscribe and client.connect calls to main function
This commit is contained in:
Daniel López Azaña 2024-03-28 20:55:23 +01:00
parent 5c80b291fc
commit 68f73131aa
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/ls_client.rs
View File

@ -148,7 +148,10 @@ impl LightstreamerClient {
/// ///
/// See also `ConnectionDetails.setServerAddress()` /// See also `ConnectionDetails.setServerAddress()`
pub fn connect(&mut self) -> Result<(), IllegalStateException> { pub fn connect(&mut self) -> Result<(), IllegalStateException> {
// Implementation for connect if self.server_address.is_none() {
return Err(IllegalStateException::new("No server address was configured."));
}
Ok(()) Ok(())
} }

14
src/main.rs
View File

@ -210,7 +210,7 @@ impl SubscriptionListener for MySubscriptionListener {
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> { async fn main() -> Result<(), Box<dyn Error>> {
let mut subscription = Subscription::new( let mut my_subscription = Subscription::new(
SubscriptionMode::Merge, SubscriptionMode::Merge,
Some(vec![ Some(vec![
"item1".to_string(), "item1".to_string(),
@ -220,17 +220,19 @@ async fn main() -> Result<(), Box<dyn Error>> {
Some(vec!["stock_name".to_string(), "last_price".to_string()]), Some(vec!["stock_name".to_string(), "last_price".to_string()]),
)?; )?;
subscription.add_listener(Box::new(MySubscriptionListener {})); my_subscription.set_data_adapter(Some(String::from("QUOTE_ADAPTER")))?;
subscription.set_data_adapter(Some(String::from("QUOTE_ADAPTER")))?; my_subscription.set_requested_snapshot(Some(Snapshot::Yes))?;
subscription.set_requested_snapshot(Some(Snapshot::Yes))?; my_subscription.add_listener(Box::new(MySubscriptionListener {}));
let client = LightstreamerClient::new( let mut client = LightstreamerClient::new(
Some("http://push.lightstreamer.com/lightstreamer"), Some("http://push.lightstreamer.com/lightstreamer"),
Some("DEMO"), Some("DEMO"),
)?; )?;
println!("Subscription: {:?}", subscription); client.subscribe(my_subscription);
println!("Client: {:?}", client); println!("Client: {:?}", client);
client.connect();
Ok(()) Ok(())
} }