decreases the part for when the kuksa client is locked in the zenoh-k…

…uksa-provider
boschglobal · Oct 18, 2024 · 545bd99 · 545bd99
1 parent 565e6f2
commit 545bd99
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/zenoh-kuksa-provider/Cargo.toml b/zenoh-kuksa-provider/Cargo.toml
@@ -12,6 +12,8 @@
 ########################################################################
 
 
+[workspace]
+
 [package]
 name = "zenoh-kuksa-provider"
 version = "0.1.0"

diff --git a/zenoh-kuksa-provider/src/main.rs b/zenoh-kuksa-provider/src/main.rs
@@ -55,8 +55,6 @@ async fn handling_zenoh_subscribtion(
 ) {
     info!("Listening on selector: {:?}", provider_config.zenoh.key_exp);
 
-    let mut sub_client = kuksa_client.lock().await;
-
     let provider_config_clone = Arc::clone(&provider_config);
     let subscriber = session
         .declare_subscriber(provider_config_clone.zenoh.key_exp.clone())
@@ -79,11 +77,13 @@ async fn handling_zenoh_subscribtion(
         if field_type == "currentValue" {
             let datapoint_update = new_datapoint_for_update(&vss_path, &sample, &store);
 
+            let mut sub_client = kuksa_client.lock().await;
             debug!("Forwarding: {:#?}", datapoint_update);
             sub_client
                 .set_current_values(datapoint_update)
                 .await
                 .unwrap();
+            drop(sub_client);
         }
     }
 }