1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

mod quin;

use std::{net::SocketAddr, time::Duration};

pub use quin::*;

pub async fn try_connect_forever(
    quic_client: &self::Client,
    addr: SocketAddr,
    name: &str,
) -> (self::SendStream, self::RecvStream) {
    loop {
        log::info!("Connecting to node {addr} - {name}");
        if let Ok(connection) = quic_client.connect(addr, name, 1).await {
            return connection;
        }
        log::warn!("Failed to connect to node {addr} - {name}, retrying...");
        tokio::time::sleep(Duration::from_secs(2)).await;
    }
}