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

use crate::prelude::RxError;
use std::fmt::Debug;

#[derive(Clone, Debug)]
pub enum Material<T>
where
  T: Clone + Send + Sync,
{
  Next(T),
  Error(RxError),
  Complete,
}

#[cfg(test)]
mod test {
  use crate::prelude::*;

  #[test]
  fn basic() {
    println!("{:?}", Material::Next(0));
    println!(
      "{:?}",
      Material::Error::<i32>(RxError::from_error("ERR!"))
    );
    println!("{:?}", Material::Complete::<i32>);
  }

  #[test]
  fn omit_scope() {
    use Material::*;
    println!("{:?}", Next(0));
    println!(
      "{:?}",
      Error::<i32>(RxError::from_error("ERR!"))
    );
    println!("{:?}", Complete::<i32>);
  }

  #[test]
  fn custom_type() {
    use Material::*;
    #[derive(Clone)]
    struct X {}
    let x = Next(X {});
    // println!("{:?}", x); // compile error
    match x {
      Next(_) => println!("Next"),
      Error(_) => println!("Error"),
      Complete => println!("Complete"),
    }
  }
}