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

cleaned up warnings

Browse source
This commit is contained in:
Nickiel12 2021-12-17 12:38:56 -08:00
parent b302539831
commit 5264001ab5
2 changed files with 7 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/modules/states_io_handler.rs
View file

@ -1,6 +1,6 @@
use std::{sync::mpsc::{Sender, self, Receiver}, thread::{JoinHandle, self}};
use super::{message_handler::{MessageHandler, StateMessage}, stream_states::{enums::StateUpdate, stream_states_class::StreamState}};
use super::{message_handler::{MessageHandler, StateMessage}, stream_states::{stream_states_class::StreamState}};
pub struct StatesIOHandler {
@ -16,7 +16,7 @@ impl StatesIOHandler {
}
}
pub fn start_socket_listener(&mut self, mut message_handler: impl MessageHandler + Send + 'static, socket_addr: &str) {
pub fn start_socket_listener(&mut self, mut message_handler: impl MessageHandler + Send + 'static) {
let (tx, rx) = mpsc::channel::<StateMessage>();
let (tx_1, rx_1) = mpsc::channel::<StreamState>();
self.message_thread_tx = Some(tx);

11
src/tests/states_io_handler_tests.rs
View file

@ -1,6 +1,6 @@
use std::thread;
use crate::modules::{states_io_handler::{StatesIOHandler}, message_handler::{MessageHandler, StateMessage}, stream_states::{stream_states_class::StreamState, enums::StateUpdate}};
use crate::modules::{states_io_handler::{StatesIOHandler}, message_handler::{StateMessage}, stream_states::{stream_states_class::StreamState, enums::StateUpdate}};
#[test]
@ -8,7 +8,7 @@ fn test_make_socket() {
let state = StreamState::new();
let mut io_handler = StatesIOHandler::new();
io_handler.start_socket_listener(state, "no-one cares");
io_handler.start_socket_listener(state);
let tx = io_handler.message_thread_tx.clone().unwrap();
tx.send(StateMessage::StateUpdate(StateUpdate::SceneIsAugmented(true))).unwrap();
@ -25,7 +25,7 @@ fn send_on_multiple_threads() {
let state = StreamState::new();
let mut io_handler = StatesIOHandler::new();
io_handler.start_socket_listener(state, "no-one cares");
io_handler.start_socket_listener(state);
let tx1 = io_handler.message_thread_tx.clone().unwrap();
let tx2 = io_handler.message_thread_tx.clone().unwrap();
@ -56,13 +56,12 @@ fn send_on_multiple_threads() {
fn io_handler_not_started_1() {
let io_handler = StatesIOHandler::new();
let state = io_handler.get_states();
let _state = io_handler.get_states();
}
#[test]
#[should_panic]
fn io_handler_not_started_2() {
let io_handler = StatesIOHandler::new();
let state = io_handler.close();
let _state = io_handler.close();
}