clone-stream 0.4.1

Turn any Stream into a cloneable stream where each clone receives all items independently.
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

use std::fmt;

/// Errors that can occur when working with cloned streams

#[derive(Debug, Clone, PartialEq, Eq)]
pub enum CloneStreamError {
    /// The maximum number of clones has been exceeded
    MaxClonesExceeded {
        max_allowed: usize,
        current_count: usize,
    },
    /// Invalid clone ID provided
    InvalidCloneId { clone_id: usize },
    /// Clone is already active
    CloneAlreadyActive { clone_id: usize },
}

impl fmt::Display for CloneStreamError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Self::MaxClonesExceeded {
                max_allowed,
                current_count,
            } => write!(
                f,
                "Maximum number of clones exceeded: {current_count} >= {max_allowed}"
            ),
            Self::InvalidCloneId { clone_id } => {
                write!(f, "Invalid clone ID: {clone_id}")
            }
            Self::CloneAlreadyActive { clone_id } => {
                write!(f, "Clone {clone_id} is already active")
            }
        }
    }
}

impl std::error::Error for CloneStreamError {}

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