From d69b7951ae06ba6b448295fb1a5b224d3a963c9d Mon Sep 17 00:00:00 2001 From: Rob Date: Thu, 5 Dec 2024 19:00:31 -0500 Subject: [PATCH] futures -> tokio select --- sequencer/src/lib.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sequencer/src/lib.rs b/sequencer/src/lib.rs index 79475b6ae..243e12339 100644 --- a/sequencer/src/lib.rs +++ b/sequencer/src/lib.rs @@ -18,11 +18,11 @@ use espresso_types::{ traits::EventConsumer, BackoffParams, L1ClientOptions, NodeState, PubKey, SeqTypes, SolverAuctionResultsProvider, ValidatedState, }; -use futures::FutureExt; use genesis::L1Finalized; use hotshot::traits::election::static_committee::StaticCommittee; use hotshot_types::traits::election::Membership; use std::sync::Arc; +use tokio::select; // Should move `STAKE_TABLE_CAPACITY` in the sequencer repo when we have variate stake table support use libp2p::Multiaddr; use network::libp2p::split_off_peer_id; @@ -469,11 +469,11 @@ pub async fn init_node( })?; tracing::warn!("Waiting for at least one connection to be initialized"); - futures::select! { - _ = cdn_network.wait_for_ready().fuse() => { + select! { + _ = cdn_network.wait_for_ready() => { tracing::warn!("CDN connection initialized"); }, - _ = p2p_network.wait_for_ready().fuse() => { + _ = p2p_network.wait_for_ready() => { tracing::warn!("P2P connection initialized"); }, };