summaryrefslogtreecommitdiffstats
path: root/crates/core
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-07-06 09:00:25 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-07-06 09:00:25 +0200
commit692ba07615e4fef386bb27d9b70aa0e7ec957006 (patch)
treec9e2749d4213acbe2b943f1424f1fcf551618bc2 /crates/core
parent268c2a83e3fb9ac71f6eb47c72876a117e96ed2f (diff)
Format benchmark code
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
Diffstat (limited to 'crates/core')
-rw-r--r--crates/core/tedge_core/benches/simple_throughput.rs5
1 files changed, 3 insertions, 2 deletions
diff --git a/crates/core/tedge_core/benches/simple_throughput.rs b/crates/core/tedge_core/benches/simple_throughput.rs
index b7c53f16..79c13c41 100644
--- a/crates/core/tedge_core/benches/simple_throughput.rs
+++ b/crates/core/tedge_core/benches/simple_throughput.rs
@@ -1,8 +1,8 @@
use std::sync::Arc;
use async_trait::async_trait;
+use criterion::BenchmarkId;
use criterion::{criterion_group, criterion_main, Criterion};
-use criterion::{BenchmarkId};
use tedge_api::plugin::{Handle, HandleTypes};
use tedge_api::PluginConfiguration;
use tedge_api::PluginDirectory;
@@ -77,7 +77,8 @@ impl Plugin for ProducerPlugin {
while let Some(num) = rec.recv().await {
count += 1;
//println!("Sending msg #{}", count);
- addr.send_and_wait(Measurement(num)).await
+ addr.send_and_wait(Measurement(num))
+ .await
.unwrap_or_else(|_| {
println!("Could not send in sender for msg num #{}", count);
panic!();