pub async fn connect(addrs: &[impl tokio::net::ToSocketAddrs]) -> Result<Self, anyhow::Error> {
        let mut remotes = Vec::with_capacity(addrs.len());
        for addr in addrs.iter() {
            remotes.push(tcp::TcpClient::connect(addr).await?);
        }
        Ok(Self {
            client: Partitioned::new(remotes),
        })
    }
/// Construct a client backed by multiple tcp connections
Construct a client backed by multiple tcp connections
Construct a client backed by multiple tcp connections
pub async fn connect(addrs: &[impl tokio::net::ToSocketAddrs]) -> Result<Self, anyhow::Error> {
        let mut remotes = Vec::with_capacity(addrs.len());
        for addr in addrs.iter() {
            remotes.push(tcp::TcpClient::connect(addr).await?);
        }
        Ok(Self {
            client: Partitioned::new(remotes),
        })
    }
pub async fn connect ( addrs : & [ impl tokio :: net :: ToSocketAddrs ] ) -> Result < Self , anyhow :: Error > { let mut remotes = Vec :: with_capacity ( addrs . len ( ) ) ; for addr in addrs . iter ( ) { remotes . push ( tcp :: TcpClient :: connect ( addr ) . await ? ) ; } Ok ( Self { client : Partitioned :: new ( remotes ) , } ) }
Construct a client backed by multiple tcp connections
Construct a client backed by multiple tcp connections
addrs
&[impl tokio::net::ToSocketAddrs]
addrs
&[impl tokio::net::ToSocketAddrs]