asupersync 0.3.1

Spec-first, cancel-correct, capability-secure async runtime for Rust.
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
51
52
53
54
55
56

//! Error types for HTTP/3 client operations.

use h3::error::{ConnectionError, StreamError};
use thiserror::Error;

/// Error type for HTTP/3 client operations.
#[derive(Debug, Error)]
pub enum H3Error {
    /// Connection-level error reported by the HTTP/3 stack.
    #[error("h3 connection error: {0}")]
    Connection(#[from] ConnectionError),

    /// Stream-level error reported by the HTTP/3 stack.
    #[error("h3 stream error: {0}")]
    Stream(#[from] StreamError),

    /// Operation was cancelled via `Cx` cancellation.
    #[error("cancelled")]
    Cancelled,

    /// I/O error.
    #[error("I/O error: {0}")]
    Io(#[from] std::io::Error),
}

impl H3Error {
    /// Returns `true` if this error represents cancellation.
    #[must_use]
    pub fn is_cancelled(&self) -> bool {
        matches!(self, Self::Cancelled)
    }
}

impl From<crate::error::Error> for H3Error {
    fn from(err: crate::error::Error) -> Self {
        if err.is_cancelled() {
            Self::Cancelled
        } else {
            Self::Io(std::io::Error::other(err.to_string()))
        }
    }
}

#[cfg(test)]
mod tests {
    use super::H3Error;
    use crate::error::Error;
    use crate::types::CancelReason;

    #[test]
    fn cancelled_error_maps() {
        let err = Error::cancelled(&CancelReason::user("test"));
        let mapped = H3Error::from(err);
        assert!(mapped.is_cancelled());
    }
}