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
pub mod compress; pub mod decompress; pub use compress::*; pub use decompress::*; #[derive(thiserror::Error, Debug)] pub enum Error { #[error("Zstd failure: {:?}", 0)] Zstd(#[source] std::io::Error), #[error("IO error: {:?}", 0)] IO(#[source] std::io::Error), #[error("Failed to prost encode: {:?}", 0)] ProstEncode( #[from] #[source] prost::EncodeError, ), #[error("Failed to prost decode: {:?}", 0)] ProstDecode( #[from] #[source] prost::DecodeError, ), } #[cfg(feature = "enable-async")] #[derive(thiserror::Error, Debug)] pub enum StreamError<E: std::fmt::Debug> { #[error("Prosto: {:?}", 0)] Prosto(#[source] Error), #[error("Other: {:?}", 0)] Other(E), }