wombo 0.1.2

Utilities for managing event loop threads.
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
68

#![allow(unused_imports)]
#![allow(dead_code)]
#![allow(unused_variables)]

extern crate futures;
extern crate wombo;
extern crate tokio_timer;

use futures::Future;
use tokio_timer::Timer;

use std::thread;
use std::time::Duration;

use wombo::*;

const SHOULD_INTERRUPT: bool = true;

fn main() {
  // expected value when not interrupted
  let foo = 1;
  // expected value when interrupted
  let bar = 2;

  let timer = Timer::default();
  let sleep_dur = Duration::from_millis(50);

  let wombo = Wombo::new();
  let options = ThreadOptions::new("loop-1", None);

  let spawn_result = wombo.spawn(options, move |handle, hooks| {
    // sleep for a second, then return foo, or if canceled return bar
    let dur = Duration::from_millis(1000);

    hooks.on_cancel(move || Ok(bar));

    timer.sleep(dur)
      .map_err(|_| ())
      .and_then(move |_| Ok(foo))
  });

  if let Err(e) = spawn_result {
    panic!("Error spawning event loop thread: {:?}", e);
  }

  // give the child thread a chance to initialize
  thread::sleep(sleep_dur);

  assert!(wombo.is_running());
  println!("Wombo {} running thread {:?}", wombo.id(), wombo.core_thread_id());

  if SHOULD_INTERRUPT {
    if let Err(e) = wombo.cancel() {
      panic!("Error canceling: {:?}", e);
    }
  }

  let result = match wombo.on_exit() {
    Ok(rx) => rx.wait().unwrap(),
    Err(e) => panic!("Error calling on_exit: {:?}", e)
  };

  if SHOULD_INTERRUPT {
    assert_eq!(result, Some(bar));
  }else{
    assert_eq!(result, Some(foo));
  }
}