tokio_mpmc/
errors.rs

1use thiserror::Error;
2
3#[derive(Error, Debug)]
4pub enum ChannelError {
5    #[error("Channel is full")]
6    ChannelFull,
7    #[error("Channel is closed")]
8    ChannelClosed,
9}
10
11#[derive(Error, Debug)]
12pub enum QueueError {
13    #[error("Queue is full")]
14    QueueFull,
15    #[error("Queue is closed")]
16    QueueClosed,
17}