Skip to content
This repository has been archived by the owner on Oct 31, 2024. It is now read-only.

Commit

Permalink
fix: fix cargo xclippy
Browse files Browse the repository at this point in the history
  • Loading branch information
gruberb committed Jul 26, 2023
1 parent e2c0b0e commit 2b31655
Showing 1 changed file with 6 additions and 9 deletions.
15 changes: 6 additions & 9 deletions crates/topos-tce-broadcast/benches/task_manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -96,26 +96,23 @@ pub async fn processing_double_echo(n: u64) {

for cert in &certificates {
for p in &double_echo_selected_echo {
double_echo.handle_echo(p.clone(), cert.id).await;
double_echo.handle_echo(*p, cert.id).await;
}

for p in &double_echo_selected_ready {
double_echo.handle_ready(p.clone(), cert.id).await;
double_echo.handle_ready(*p, cert.id).await;
}
}

let mut count = 0;

while let Some(event) = ctx.event_receiver.recv().await {
match event {
ProtocolEvents::CertificateDelivered { .. } => {
count += 1;
if let ProtocolEvents::CertificateDelivered { .. } = event {
count += 1;

if count == n {
break;
}
if count == n {
break;
}
_ => {}
}
}
}

0 comments on commit 2b31655

Please sign in to comment.