diff options
author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-07-06 09:00:25 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-07-06 09:00:25 +0200 |
commit | 692ba07615e4fef386bb27d9b70aa0e7ec957006 (patch) | |
tree | c9e2749d4213acbe2b943f1424f1fcf551618bc2 /crates/core | |
parent | 268c2a83e3fb9ac71f6eb47c72876a117e96ed2f (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.rs | 5 |
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!(); |