updates now updates the state

This commit is contained in:
Nickiel12 2021-12-19 16:59:26 -08:00
parent 0c8931b984
commit 227d165e20

View file

@ -13,7 +13,7 @@ mod modules;
const SERVER_ADDRESS: &str = "10.0.0.168:5000"; const SERVER_ADDRESS: &str = "10.0.0.168:5000";
fn main() { fn main() {
let state = StreamState::new(); let mut state = StreamState::new();
let socket_listener = Socket::make_listener(SERVER_ADDRESS); let socket_listener = Socket::make_listener(SERVER_ADDRESS);
let (from_socket_tx, from_socket_rx) = mpsc::channel::<String>(); let (from_socket_tx, from_socket_rx) = mpsc::channel::<String>();
@ -31,6 +31,7 @@ fn main() {
println!("{}", message); println!("{}", message);
let json = serde_json::from_str(&message[1..]).unwrap(); let json = serde_json::from_str(&message[1..]).unwrap();
let update = StateUpdate::json_to_state_update(json); let update = StateUpdate::json_to_state_update(json);
state.handle_update(update);
}, },
Err(_) => {continue}, Err(_) => {continue},
} }