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

added multi-input test

Browse source
This commit is contained in:
Nickiel12 2021-12-16 15:47:14 -08:00
parent 0cdd74b917
commit 880956a164
1 changed files with 31 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/tests/io_handler_tests.rs
View file

@ -18,4 +18,35 @@ fn test_make_socket() {
let final_state = io_handler.close();
assert_eq!(final_state.scene_is_augmented, true);
assert_eq!(final_state.stream_is_muted, true);
}
#[test]
fn send_on_multiple_threads() {
let state = StreamState::new();
let mut io_handler = IOHandler::new();
io_handler.start_socket_listener(state, "no-one cares");
let tx1 = io_handler.message_thread_tx.clone().unwrap();
let tx2 = io_handler.message_thread_tx.clone().unwrap();
let tx3 = io_handler.message_thread_tx.clone().unwrap();
thread::spawn( move || {
tx1.send(StateMessage::StateUpdate(StateUpdate::TimerCanRun(false))).unwrap();
});
thread::spawn(move || {
tx2.send(StateMessage::StateUpdate(StateUpdate::ChangeSceneOnChangeSlideHotkey(false))).unwrap();
});
thread::spawn(move || {
tx3.send(StateMessage::StateUpdate(StateUpdate::StreamIsMuted(false))).unwrap();
tx3.send(StateMessage::StateUpdate(StateUpdate::StreamIsMuted(true))).unwrap();
});
thread::sleep(std::time::Duration::from_millis(1000));
let final_state = io_handler.close();
assert_eq!(final_state.timer_can_run, false);
assert_eq!(final_state.change_scene_on_change_slide_hotkey, false);
assert_eq!(final_state.stream_is_muted, true);
}