From 68f73131aa0f993bfc1bfa622be63f8862661c16 Mon Sep 17 00:00:00 2001 From: Daniel López Azaña Date: Thu, 28 Mar 2024 20:55:23 +0100 Subject: ♻️ (ls_client.rs): refactor connect method to check server_address before connecting ✨ (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 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main.rs | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index 5c2acc5..c120c1f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -210,7 +210,7 @@ impl SubscriptionListener for MySubscriptionListener { #[tokio::main] async fn main() -> Result<(), Box> { - let mut subscription = Subscription::new( + let mut my_subscription = Subscription::new( SubscriptionMode::Merge, Some(vec![ "item1".to_string(), @@ -220,17 +220,19 @@ async fn main() -> Result<(), Box> { Some(vec!["stock_name".to_string(), "last_price".to_string()]), )?; - subscription.add_listener(Box::new(MySubscriptionListener {})); - subscription.set_data_adapter(Some(String::from("QUOTE_ADAPTER")))?; - subscription.set_requested_snapshot(Some(Snapshot::Yes))?; + my_subscription.set_data_adapter(Some(String::from("QUOTE_ADAPTER")))?; + my_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("DEMO"), )?; - println!("Subscription: {:?}", subscription); + client.subscribe(my_subscription); println!("Client: {:?}", client); + client.connect(); + Ok(()) } -- cgit v1.2.3