testtools 0.1.3

Helpers for eliminating boilerplate code in tests
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

use std::thread;

use testtools::sync::Checkpoint;

#[derive(PartialEq, Eq, Hash, Clone)]
enum CkPt {
  First,
  Second,
  Third
}

#[test]
fn two() {
  let sync = Checkpoint::new();

  let tsync = sync.clone();
  thread::spawn(move || {
    tsync.waitfor([CkPt::First]).reached(CkPt::Second);
  });

  sync.reached(CkPt::First).waitfor([CkPt::Second]);
}

#[test]
fn multi() {
  let sync = Checkpoint::new();

  let tsync1 = sync.clone();
  thread::spawn(move || {
    tsync1.waitfor([CkPt::First]).reached(CkPt::Second);
  });

  let tsync2 = sync.clone();
  thread::spawn(move || {
    tsync2.waitfor([CkPt::First]).reached(CkPt::Third);
  });

  sync
    .reached(CkPt::First)
    .waitfor([CkPt::Second, CkPt::Third]);
}

#[test]
fn async_test() {
  let sync = Checkpoint::new();

  let tokrt = tokio::runtime::Runtime::new().unwrap();

  let tsync1 = sync.clone();
  let _jh = testtools::thread::spawn_autojoin(move || {
    tsync1.waitfor([CkPt::First]);
    tsync1.reached(CkPt::Second);
  });

  let tsync2 = sync.clone();
  tokrt.block_on(async {
    tsync2.reached(CkPt::First);
    tsync2.async_waitfor([CkPt::Second]).await;
  });
}

// vim: set ft=rust et sw=2 ts=2 sts=2 cinoptions=2 tw=79 :