diff --git a/src/main.rs b/src/main.rs index 2550b36..073a188 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,17 +1,26 @@ -use std::thread; use launchpad::core::events::{Event, Severity}; -use std::sync::mpsc::{channel}; +use std::sync::mpsc::channel; +use std::thread; + fn main() { + basic_event_test(); +} + +fn basic_event_test() { let test_event_0 = Event::new(Severity::INFO, 0, 0); let (event_sender, event_receiver) = channel(); let t0_sender = event_sender.clone(); let t0 = thread::spawn(move || { - t0_sender.send(test_event_0.unwrap()).expect("Sending event from t0 failed"); + t0_sender + .send(test_event_0.unwrap()) + .expect("Sending event from t0 failed"); }); let test_event_1 = Event::new(Severity::MEDIUM, 1, 8); let t1 = thread::spawn(move || { - event_sender.send(test_event_1.unwrap()).expect("Sending event from t1 failed"); + event_sender + .send(test_event_1.unwrap()) + .expect("Sending event from t1 failed"); }); let mut event_cntr = 0; @@ -21,11 +30,12 @@ fn main() { println!("Received event {:?}", event); event_cntr += 1; } - Err(_) => { () + Err(_) => { + () // println!("Received error {:?}", error); } } - }; + } t0.join().unwrap(); t1.join().unwrap(); }