@@ -65,6 +65,7 @@ fn test_compile() {
65
65
66
66
#[ test]
67
67
fn test_run ( ) {
68
+ println ! ( "* Starting test_run." ) ;
68
69
let ( tx, rx) : ( _ , Receiver < Event > ) = channel ( ) ;
69
70
70
71
let tx_env = Box :: new ( tx. map ( |event| Event :: Env ( event) ) ) ;
@@ -75,6 +76,7 @@ fn test_run() {
75
76
let env = FakeEnv :: new ( tx_env) ;
76
77
let mut exec = Execution :: < FakeEnv > :: new ( ) ;
77
78
79
+ println ! ( "* Spawning thread." ) ;
78
80
thread:: spawn ( move || {
79
81
for msg in rx {
80
82
if let Event :: Env ( FakeEnvEvent :: Done ) = msg {
@@ -83,11 +85,12 @@ fn test_run() {
83
85
tx_send. send ( ( id, value) ) . unwrap ( ) ;
84
86
} else {
85
87
// Can be useful for debugging, but that's generally noise.
86
- // println!("LOG: {:?}", msg)
88
+ println ! ( "LOG: {:?}" , msg)
87
89
}
88
90
}
89
91
} ) ;
90
92
93
+ println ! ( "* Preparing script." ) ;
91
94
let script_1 = Script {
92
95
name : "Test script" . to_owned ( ) ,
93
96
rules : vec ! [
@@ -485,7 +488,7 @@ fn sleep<T>(rx_done: &Receiver<()>, rx_send: &Receiver<(Id<Setter>, Value)>, rx_
485
488
486
489
#[ test]
487
490
fn test_run_with_delay ( ) {
488
- let ( tx, rx) : ( _ , Receiver < Event > ) = channel ( ) ;
491
+ { let ( tx, rx) : ( _ , Receiver < Event > ) = channel ( ) ;
489
492
490
493
let tx_env = Box :: new ( tx. map ( |event| Event :: Env ( event) ) ) ;
491
494
let tx_run = tx. map ( |event| Event :: Run ( event) ) ;
@@ -768,7 +771,7 @@ fn test_run_with_delay() {
768
771
rx_done. try_recv ( ) . unwrap_err ( ) ;
769
772
rx_send. try_recv ( ) . unwrap_err ( ) ;
770
773
771
- println ! ( "* Cleanup complete." ) ;
774
+ println ! ( "* Cleanup complete." ) ; }
772
775
773
- println ! ( "" ) ;
776
+ println ! ( "* Drop complete. " ) ;
774
777
}
0 commit comments