diff --git a/src/imex/transfer.rs b/src/imex/transfer.rs index d61cbd775..5021d78df 100644 --- a/src/imex/transfer.rs +++ b/src/imex/transfer.rs @@ -97,12 +97,14 @@ impl BackupProvider { /// [`Accounts::stop_io`]: crate::accounts::Accounts::stop_io pub async fn prepare(context: &Context) -> Result { let relay_mode = RelayMode::Disabled; - let endpoint = Endpoint::builder() - .tls_x509() // For compatibility with iroh <0.34.0 - .alpns(vec![BACKUP_ALPN.to_vec()]) - .relay_mode(relay_mode) - .bind() - .await?; + let endpoint = Box::pin( + Endpoint::builder() + .tls_x509() // For compatibility with iroh <0.34.0 + .alpns(vec![BACKUP_ALPN.to_vec()]) + .relay_mode(relay_mode) + .bind(), + ) + .await?; let node_addr = endpoint.node_addr().await?; // Acquire global "ongoing" mutex. @@ -308,12 +310,14 @@ pub async fn get_backup2( let mut transport_config = iroh::endpoint::TransportConfig::default(); transport_config.max_idle_timeout(Some(Duration::from_secs(60).try_into()?)); - let endpoint = Endpoint::builder() - .tls_x509() // For compatibility with iroh <0.34.0 - .relay_mode(relay_mode) - .transport_config(transport_config) - .bind() - .await?; + let endpoint = Box::pin( + Endpoint::builder() + .tls_x509() // For compatibility with iroh <0.34.0 + .relay_mode(relay_mode) + .transport_config(transport_config) + .bind(), + ) + .await?; let conn = endpoint.connect(node_addr, BACKUP_ALPN).await?; let (mut send_stream, mut recv_stream) = conn.open_bi().await?; diff --git a/src/peer_channels.rs b/src/peer_channels.rs index 0ad5a8e65..9e7e8a1af 100644 --- a/src/peer_channels.rs +++ b/src/peer_channels.rs @@ -253,13 +253,15 @@ impl Context { RelayMode::Default }; - let endpoint = Endpoint::builder() - .tls_x509() // For compatibility with iroh <0.34.0 - .secret_key(secret_key) - .alpns(vec![GOSSIP_ALPN.to_vec()]) - .relay_mode(relay_mode) - .bind() - .await?; + let endpoint = Box::pin( + Endpoint::builder() + .tls_x509() // For compatibility with iroh <0.34.0 + .secret_key(secret_key) + .alpns(vec![GOSSIP_ALPN.to_vec()]) + .relay_mode(relay_mode) + .bind(), + ) + .await?; // create gossip // Allow messages up to 128 KB in size.