Use futures pin instead of tokio

This commit is contained in:
Luke Parker
2022-11-08 22:56:46 -05:00
parent f7b1ff9f3b
commit 7d46daa36e

View File

@@ -340,11 +340,10 @@ impl<N: Network + 'static> TendermintMachine<N> {
})
.fuse()
};
tokio::pin! {
let propose_timeout = timeout_future(Step::Propose);
let prevote_timeout = timeout_future(Step::Prevote);
let precommit_timeout = timeout_future(Step::Precommit);
};
let propose_timeout = timeout_future(Step::Propose);
let prevote_timeout = timeout_future(Step::Prevote);
let precommit_timeout = timeout_future(Step::Precommit);
futures::pin_mut!(propose_timeout, prevote_timeout, precommit_timeout);
// Also create a future for if the queue has a message
// Does not pop_front as if another message has higher priority, its future will be handled