Merge branch 'feature/add_tedge_api/optimize-bench' into feature/add_tedge_api_impl

1 files changed, 8 insertions, 16 deletions

diff --git a/crates/core/tedge_core/benches/simple_throughput.rs b/crates/core/tedge_core/benches/simple_throughput.rs
index 2f17635f..44a87c46 100644
--- a/crates/core/tedge_core/benches/simple_throughput.rs
+++ b/crates/core/tedge_core/benches/simple_throughput.rs
@@ -73,22 +73,14 @@ impl Plugin for ProducerPlugin {
         let addr = self.1.clone();
         let mut count = 0;
         tokio::spawn(async move {
-            loop {
-                tokio::select! {
-                    num = rec.recv() => {
-                        if let Some(num) = num {
-                            count += 1;
-                            //println!("Sending msg #{}", count);
-                            addr.send_and_wait(Measurement(num)).await
-                                .unwrap_or_else(|_| {
-                                    println!("Could not send in sender for msg num #{}", count);
-                                    panic!();
-                                });
-                        } else {
-                            break
-                        }
-                    }
-                }
+            while let Some(num) = rec.recv().await {
+                count += 1;
+                //println!("Sending msg #{}", count);
+                addr.send_and_wait(Measurement(num)).await
+                    .unwrap_or_else(|_| {
+                        println!("Could not send in sender for msg num #{}", count);
+                        panic!();
+                    });
             }
         });