h3-util 0.0.1

h3 utilities for tonic-h3
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use http::Uri;
use hyper::body::Bytes;

use crate::client::H3Connector;

#[derive(Clone)]
pub struct H3QuinnConnector {
    uri: Uri,
    server_name: String,
    ep: h3_quinn::quinn::Endpoint,
}

impl H3QuinnConnector {
    pub fn new(uri: Uri, server_name: String, ep: h3_quinn::quinn::Endpoint) -> Self {
        Self {
            uri,
            server_name,
            ep,
        }
    }
}

impl H3Connector for H3QuinnConnector {
    type CONN = h3_quinn::Connection;
    type OS = h3_quinn::OpenStreams;
    type SS = h3_quinn::SendStream<Bytes>;
    type RS = h3_quinn::RecvStream;
    type OE = h3_quinn::ConnectionError;
    type BS = h3_quinn::BidiStream<Bytes>;
    async fn connect(&self) -> Result<Self::CONN, crate::Error> {
        // connect to dns resolved addr.
        let mut conn_err = std::io::Error::from(std::io::ErrorKind::AddrNotAvailable).into();
        let addrs = crate::client::dns_resolve(&self.uri).await?;
        tracing::debug!("connecting to server: {:?}", addrs);
        for addr in addrs {
            match self
                .ep
                .connect(addr, &self.server_name)
                .map_err(Into::<crate::Error>::into)
            {
                Ok(conn) => {
                    let x = conn.await.map_err(Into::<crate::Error>::into)?;
                    return Ok(h3_quinn::Connection::new(x));
                }
                Err(e) => conn_err = e,
            }
        }
        Err(conn_err)
    }
}