another-rxrust 0.0.46

A different implementation than `rxRust` for easier use of `ReactiveX` in `Rust`.
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

use std::fmt::Display;
use std::sync::{Arc, RwLock};

pub struct DestructChecker {
  memo: &'static str,
  n: usize,
  ref_count: Arc<RwLock<usize>>,
}
impl DestructChecker {
  pub fn new(memo: &'static str) -> DestructChecker {
    DestructChecker {
      memo,
      n: 0,
      ref_count: Arc::new(RwLock::new(0)),
    }
  }
}
impl Drop for DestructChecker {
  fn drop(&mut self) {
    if *self.ref_count.read().unwrap() == 0 {
      println!("destructed {}", self.memo);
    } else {
      *self.ref_count.write().unwrap() -= 1;
      println!("dropped {} #{}", self.memo, self.n);
    }
  }
}
impl Clone for DestructChecker {
  fn clone(&self) -> Self {
    *self.ref_count.write().unwrap() += 1;
    println!(
      "clone {} #{} -> #{}",
      self.memo,
      self.n,
      *self.ref_count.read().unwrap()
    );
    DestructChecker {
      memo: self.memo,
      n: *self.ref_count.read().unwrap(),
      ref_count: self.ref_count.clone(),
    }
  }
  fn clone_from(&mut self, source: &Self) {
    *self.ref_count.write().unwrap() += 1;
    self.memo = source.memo;
    self.n = *self.ref_count.read().unwrap();
    self.ref_count = source.ref_count.clone();
    println!(
      "clone_from {} #{} -> #{}",
      source.memo, source.n, self.n
    );
  }
}
impl Display for DestructChecker {
  fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
    f.write_fmt(format_args!(
      "DestructChecker {} #{}",
      self.memo, self.n
    ))
  }
}