wingfoil 4.0.0

graph based stream processing framework
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

pub mod message;

pub mod kanal_chan;
pub use kanal_chan::*;

// pub mod ring_buffer;
// pub mod ring_buffer_chan;
// pub use ring_buffer_chan::*;

pub(crate) use message::*;
use std::fmt;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum SendNodeError {
    ChannelClosed,
    NotifierClosed,
}

impl fmt::Display for SendNodeError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            SendNodeError::ChannelClosed => f.write_str("channel closed"),
            SendNodeError::NotifierClosed => f.write_str("ready-notifier dropped"),
        }
    }
}

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

pub type SendResult = Result<(), SendNodeError>;

#[cfg(feature = "async")]
use crate::graph::ReadyNotifier;
#[cfg(feature = "async")]
pub type NotifierChannelSender = kanal::Sender<ReadyNotifier>;

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn channel_closed_display() {
        assert_eq!(SendNodeError::ChannelClosed.to_string(), "channel closed");
    }

    #[test]
    fn notifier_closed_display() {
        assert_eq!(
            SendNodeError::NotifierClosed.to_string(),
            "ready-notifier dropped"
        );
    }

    #[test]
    fn send_node_error_is_error() {
        let e: &dyn std::error::Error = &SendNodeError::ChannelClosed;
        assert!(e.source().is_none());
    }

    #[test]
    fn send_node_error_eq_and_copy() {
        let a = SendNodeError::ChannelClosed;
        let b = a; // Copy
        assert_eq!(a, b);
        assert_ne!(SendNodeError::ChannelClosed, SendNodeError::NotifierClosed);
    }
}