taubyte_sdk/pubsub/node/
channel.rs

1use super::Channel;
2
3impl Channel {
4    pub fn new(name: String) -> Result<Self, Box<dyn std::error::Error>> {
5        if name.len() == 0 {
6            Err("Channel name cannot be empty".into())
7        } else {
8            Ok(Self { name })
9        }
10    }
11
12    pub fn name(&self) -> String {
13        self.name.clone()
14    }
15}
16
17#[cfg(test)]
18pub mod test {
19    use super::Channel;
20
21    #[test]
22    fn channel_name() {
23        let name = "testChannel".to_string();
24        let channel = Channel::new(name.clone()).unwrap();
25        assert_eq!(channel.name(), name);
26
27        let err_name = "".to_string();
28        let err = Channel::new(err_name);
29        assert_eq!(err.is_err(), true);
30    }
31}

taubyte_sdk/pubsub/node/channel.rs

taubyte_sdk/pubsub/node/
channel.rs