hala-net 0.1.2

Hala network framework
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

use std::{fmt::Debug, io};

use super::{QuicConnState, QuicStream};

/// Quic connection between a local and a remote.
#[derive(Clone)]
pub struct QuicConn {
    pub(super) state: QuicConnState,
}

impl Debug for QuicConn {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "trace_id={}", self.state.trace_id)
    }
}

impl QuicConn {
    pub(crate) fn new(state: QuicConnState) -> Self {
        Self { state }
    }
    /// Accept new incoming stream.
    pub async fn accept(&self) -> Option<QuicStream> {
        self.state.accept().await
    }

    /// Open new outgoing stream.
    pub async fn open_stream(&self) -> io::Result<QuicStream> {
        Ok(self.state.open_stream())
    }

    /// Close current quic connection.
    pub async fn close(&self, app: bool, err: u64, reason: &[u8]) -> io::Result<()> {
        self.state.close(app, err, reason).await
    }

    /// Get `QuicConn` trace id &str
    pub fn trace_id(&self) -> &str {
        &self.state.trace_id
    }

    pub async fn is_closed(&self) -> bool {
        self.state.is_closed().await
    }
}