ezk 0.1.4

Types to build reusable media streaming components
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

use crate::ConfigRange;
use core::fmt;
use std::{convert::Infallible, error::Error as StdError};

pub type Result<T, E = Error> = std::result::Result<T, E>;

#[derive(Debug)]
pub struct Error {
    kind: ErrorKind,
    source: Box<dyn StdError + Send + Sync>,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
pub enum ErrorKind {
    NegotiationFailed,
    Other,
}

impl Error {
    pub fn new<E: StdError + Send + Sync + 'static>(kind: ErrorKind, error: E) -> Self {
        Self {
            kind,
            source: Box::new(error),
        }
    }

    pub fn negotiation_failed<A: ConfigRange, B: ConfigRange>(a: Vec<A>, b: Vec<B>) -> Self {
        Self {
            kind: ErrorKind::NegotiationFailed,
            source: Box::new(IncompatibleConfig(a, b)),
        }
    }

    pub fn msg(msg: impl Into<String>) -> Self {
        Self {
            kind: ErrorKind::Other,
            source: Box::<dyn StdError + Send + Sync>::from(msg.into()),
        }
    }

    pub fn other<E: StdError + Send + Sync + 'static>(error: E) -> Self {
        Self {
            kind: ErrorKind::Other,
            source: Box::new(error),
        }
    }

    pub fn kind(&self) -> ErrorKind {
        self.kind
    }
}

impl StdError for Error {
    fn source(&self) -> Option<&(dyn StdError + 'static)> {
        Some(&*self.source)
    }
}

impl fmt::Display for Error {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        if f.alternate() {
            let mut prev: &dyn StdError = &*self.source;

            writeln!(f, "{}", prev)?;

            while let Some(source) = prev.source() {
                writeln!(f, "  {}", source)?;
                prev = source;
            }

            Ok(())
        } else {
            self.source.fmt(f)
        }
    }
}

#[derive(Debug)]
pub struct IncompatibleConfig<A, B>(Vec<A>, Vec<B>);

impl<A: ConfigRange, B: ConfigRange> fmt::Display for IncompatibleConfig<A, B> {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "Incompatible configs: {:?} {:?}", self.0, self.1)
    }
}

impl<A: ConfigRange, B: ConfigRange> StdError for IncompatibleConfig<A, B> {}

impl From<Infallible> for Error {
    fn from(value: Infallible) -> Self {
        match value {}
    }
}