pyra_streams/error.rs
1use thiserror::Error;
2
3/// Errors that can occur in stream consumer operations.
4#[derive(Debug, Error)]
5pub enum StreamError {
6 #[error("Redis error: {0}")]
7 Redis(#[from] redis::RedisError),
8
9 #[error("Redis pool error: {0}")]
10 Pool(#[from] deadpool_redis::PoolError),
11}
12
13pub type StreamResult<T> = Result<T, StreamError>;