Nickiel/church_controller_rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

removed defunct and crashing tests

Browse source
This commit is contained in:
Nickiel12 2021-12-29 21:11:46 -08:00
parent 3ec171fd70
commit 9a2c6fa2e9
1 changed files with 1 additions and 59 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

60
src/tests/message_handler_tests.rs
View file

@ -1,6 +1,6 @@
use std::{sync::mpsc::{self, Receiver}, thread::{self, JoinHandle}};
use crate::modules::{message_handler::{MessageHandler, StateMessage}, stream_states::{state_update::StateUpdate, enums::{Scenes}, stream_states_class::StreamState}};
use crate::modules::{message_handler::{MessageHandler}, stream_states::{state_update::StateUpdate, enums::{Scenes}, stream_states_class::StreamState}};
#[test]
@ -9,61 +9,3 @@ fn does_stream_state_implement_message_handler() {
state.handle_update(StateUpdate::ToggleComputerSoundOn(false));
assert_eq!(state.computer_sound_is_on, false);
}
#[test]
fn message_hander_can_handle_basic_message() {
let (tx, rx) = mpsc::channel();
fn listen(mut handler: StreamState, rx: Receiver<StateMessage>) -> JoinHandle<()>{
thread::spawn(move || {
for message in rx {
match message {
StateMessage::StateUpdate(update) => {handler.handle_update(update)},
StateMessage::CloseListener => {break;},
};
}
assert_eq!(handler.computer_sound_is_on, false);
})
}
let handler = StreamState::new();
let join_handle = listen(handler, rx);
tx.send(StateMessage::StateUpdate(StateUpdate::ToggleComputerSoundOn(false))).unwrap();
thread::sleep(std::time::Duration::from_millis(1000));
tx.send(StateMessage::CloseListener).unwrap();
join_handle.join().unwrap();
}
#[test]
fn message_handler_can_handle_multiple_messages() {
let (tx, rx) = mpsc::channel();
fn listen(mut handler: StreamState, rx: Receiver<StateMessage>) -> JoinHandle<()>{
thread::spawn(move || {
for message in rx {
match message {
StateMessage::StateUpdate(update) => {handler.handle_update(update)},
StateMessage::CloseListener => {break;},
};
}
assert_eq!(handler.computer_sound_is_on, false);
assert_eq!(handler.scene_is_augmented, true);
assert_eq!(handler.scene_is_augmented, true);
assert_eq!(handler.current_scene, Scenes::Augmented);
assert_eq!(handler.timer_can_run, false);
})
}
let handler = StreamState::new();
let join_handle = listen(handler, rx);
tx.send(StateMessage::StateUpdate(StateUpdate::ToggleComputerSoundOn(false))).unwrap();
tx.send(StateMessage::StateUpdate(StateUpdate::SceneIsAugmented(true))).unwrap();
tx.send(StateMessage::StateUpdate(StateUpdate::TimerCanRun(false))).unwrap();
thread::sleep(std::time::Duration::from_millis(1000));
tx.send(StateMessage::CloseListener).unwrap();
join_handle.join().unwrap();
}