moq_mux/
error.rs

1/// Errors from moq-mux operations.
2///
3/// Most variants are delegations to underlying layers — [`moq_net::Error`] for
4/// transport / pub-sub failures, [`hang::Error`] for catalog/codec parsing, the
5/// per-format Errors for container shape problems, and the per-codec Errors for
6/// bitstream parsing problems.
7#[derive(Debug, thiserror::Error)]
8#[non_exhaustive]
9pub enum Error {
10	/// Error from the underlying moq-net transport.
11	#[error("moq: {0}")]
12	Moq(#[from] moq_net::Error),
13
14	/// Error from the hang catalog/codec layer.
15	#[error("hang: {0}")]
16	Hang(#[from] hang::Error),
17
18	/// Error publishing or consuming JSON over a track.
19	#[error("json: {0}")]
20	Json(#[from] moq_json::Error),
21
22	/// Error parsing or building CMAF moof+mdat fragments.
23	#[error("cmaf: {0}")]
24	Cmaf(#[from] crate::container::fmp4::Error),
25
26	/// Error parsing or building MKV / WebM streams.
27	#[error("mkv: {0}")]
28	Mkv(#[from] crate::container::mkv::Error),
29
30	/// Error decoding the MSF catalog.
31	#[error("msf: {0}")]
32	Msf(#[from] crate::catalog::msf::Error),
33
34	/// Error parsing or building LOC frames.
35	#[error("loc: {0}")]
36	Loc(#[from] moq_loc::Error),
37
38	/// Error parsing an Annex B NAL stream.
39	#[error("annexb: {0}")]
40	Annexb(#[from] crate::codec::annexb::Error),
41
42	/// Error parsing AAC.
43	#[error("aac: {0}")]
44	Aac(#[from] crate::codec::aac::Error),
45
46	/// Error parsing Opus.
47	#[error("opus: {0}")]
48	Opus(#[from] crate::codec::opus::Error),
49
50	/// Error parsing FLAC.
51	#[error("flac: {0}")]
52	Flac(#[from] crate::codec::flac::Error),
53
54	/// Error parsing MP3.
55	#[error("mp3: {0}")]
56	Mp3(#[from] crate::codec::mp3::Error),
57
58	/// Error parsing H.264.
59	#[error("h264: {0}")]
60	H264(#[from] crate::codec::h264::Error),
61
62	/// Error parsing H.265.
63	#[error("h265: {0}")]
64	H265(#[from] crate::codec::h265::Error),
65
66	/// Error parsing AV1.
67	#[error("av1: {0}")]
68	Av1(#[from] crate::codec::av1::Error),
69
70	/// Error parsing VP8.
71	#[error("vp8: {0}")]
72	Vp8(#[from] crate::codec::vp8::Error),
73
74	/// Error parsing VP9.
75	#[error("vp9: {0}")]
76	Vp9(#[from] crate::codec::vp9::Error),
77
78	/// Error parsing legacy audio (MP2 / AC-3 / E-AC-3).
79	#[error("legacy: {0}")]
80	Legacy(#[from] crate::codec::legacy::Error),
81
82	/// Timestamp overflow when converting between timescales.
83	#[error("timestamp overflow")]
84	TimestampOverflow(#[from] moq_net::TimeOverflow),
85
86	/// Error decoding or encoding an mp4 atom.
87	#[error("mp4: {0}")]
88	Mp4(std::sync::Arc<mp4_atom::Error>),
89
90	/// I/O error.
91	#[error("io: {0}")]
92	Io(std::sync::Arc<std::io::Error>),
93
94	/// URL parse error.
95	#[error("url: {0}")]
96	Url(#[from] url::ParseError),
97
98	/// Unknown media format.
99	#[error("unknown format: {0}")]
100	UnknownFormat(String),
101
102	/// A non-keyframe frame was received before any keyframe opened a group.
103	/// A track joining mid-stream should skip frames until the first keyframe.
104	#[error("{0}")]
105	MissingKeyframe(#[from] crate::container::MissingKeyframe),
106
107	/// Error from a muxer/demuxer that reports via `anyhow` (currently MPEG-TS).
108	/// Boxed in an `Arc` so the enum stays `Clone` (`anyhow::Error` is not).
109	#[error("{0}")]
110	Other(std::sync::Arc<anyhow::Error>),
111
112	/// Tried to set an application catalog section whose name collides with a
113	/// reserved media section (`video`/`audio`).
114	#[error("reserved catalog section: {0}")]
115	ReservedSection(String),
116}
117
118impl From<anyhow::Error> for Error {
119	fn from(err: anyhow::Error) -> Self {
120		Error::Other(std::sync::Arc::new(err))
121	}
122}
123
124impl From<mp4_atom::Error> for Error {
125	fn from(err: mp4_atom::Error) -> Self {
126		Error::Mp4(std::sync::Arc::new(err))
127	}
128}
129
130impl From<std::io::Error> for Error {
131	fn from(err: std::io::Error) -> Self {
132		Error::Io(std::sync::Arc::new(err))
133	}
134}
135
136/// A Result type alias for moq-mux operations.
137pub type Result<T> = std::result::Result<T, Error>;
moq_mux/error.rs

moq_mux/
error.rs
