h3-util 0.0.6

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

use std::sync::Arc;

use crate::server::H3Acceptor;

#[derive(Clone)]
pub struct H3MsQuicAcceptor {
    ep: Arc<tokio::sync::Mutex<msquic_h3::Listener>>,
}

impl H3MsQuicAcceptor {
    pub fn new(inner: msquic_h3::Listener) -> Self {
        Self {
            ep: Arc::new(tokio::sync::Mutex::new(inner)),
        }
    }

    /// shutdowns the acceptor and server.
    pub async fn shutdown(&self) {
        self.ep.lock().await.shutdown().await;
    }
}

impl H3Acceptor for H3MsQuicAcceptor {
    type CONN = msquic_h3::Connection;

    type OS = msquic_h3::StreamOpener;

    type SS = msquic_h3::H3SendStream;

    type RS = msquic_h3::H3RecvStream;

    type BS = msquic_h3::H3Stream;

    async fn accept(&mut self) -> Result<Option<Self::CONN>, crate::Error> {
        let conn = self.ep.lock().await.accept().await?;
        Ok(conn)
    }
}