nxtquic-api 0.1.2

High-level async API for NxtQuic
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

//! The Tokio task driving a QUIC endpoint.

/// A driver that manages a QUIC endpoint's event loop.
///
/// It handles reading incoming UDP packets, feeding them to the internal connection state machines,
/// transmitting outgoing packets, and managing timers.
pub struct EndpointDriver {
    // Inner state (socket, state machine, etc.)
}

impl EndpointDriver {
    /// Creates a new driver.
    pub fn new() -> Self {
        Self {}
    }

    /// Runs the endpoint event loop.
    pub async fn run(&mut self) {
        // Event loop that would normally:
        // - Read from `nxtquic-udp::UdpSocket`
        // - Process packets via `nxtquic-proto::Connection`
        // - Send outgoing packets
        // - Manage timeouts
        loop {
            tokio::task::yield_now().await;
            break;
        }
    }
}

impl Default for EndpointDriver {
    fn default() -> Self {
        Self::new()
    }
}