Skip to content

Commit

Permalink
Minor test fix
Browse files Browse the repository at this point in the history
  • Loading branch information
AgeManning committed Oct 17, 2024
1 parent 0871529 commit 7c32740
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions anchor/qbft/src/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -358,10 +358,10 @@ where
let mut new_senders = HashMap::with_capacity(senders.len());

// Populate the new channels.
for id in 0..receivers.len() {
for operator_id in receivers.keys() {
let (new_sender, new_receiver) = tokio::sync::mpsc::unbounded_channel::<OutMessage<D>>();
new_receivers.insert(OperatorId::from(id), new_receiver);
new_senders.insert(OperatorId::from(id), new_sender);
new_receivers.insert(operator_id.clone(), new_receiver);
new_senders.insert(operator_id.clone(), new_sender);
}

// Run a task to handle all the out messages
Expand Down

0 comments on commit 7c32740

Please sign in to comment.