diff --git a/atem-connection-rs/src/atem_lib/atem_socket.rs b/atem-connection-rs/src/atem_lib/atem_socket.rs index 2739436..59754a0 100644 --- a/atem-connection-rs/src/atem_lib/atem_socket.rs +++ b/atem-connection-rs/src/atem_lib/atem_socket.rs @@ -18,11 +18,8 @@ use tokio::{ }; use crate::{ - atem_lib::atem_packet::{self, AtemPacket, COMMAND_CONNECT_HELLO}, - commands::{ - command_base::{BasicWritableCommand, DeserializedCommand}, - parse_commands::deserialize_commands, - }, + atem_lib::atem_packet::{AtemPacket, COMMAND_CONNECT_HELLO}, + commands::command_base::{BasicWritableCommand, DeserializedCommand}, enums::ProtocolVersion, }; diff --git a/atem-connection-rs/src/commands/command_base.rs b/atem-connection-rs/src/commands/command_base.rs index e55caef..f9321b9 100644 --- a/atem-connection-rs/src/commands/command_base.rs +++ b/atem-connection-rs/src/commands/command_base.rs @@ -1,5 +1,5 @@ use std::{ - boxed::Box, collections::HashMap, fmt::Debug, process::Command, string::String, sync::Arc, + boxed::Box, collections::HashMap, fmt::Debug, string::String, sync::Arc, vec::Vec, }; diff --git a/atem-connection-rs/src/commands/parse_commands.rs b/atem-connection-rs/src/commands/parse_commands.rs index 3c4eb21..c8458f2 100644 --- a/atem-connection-rs/src/commands/parse_commands.rs +++ b/atem-connection-rs/src/commands/parse_commands.rs @@ -1,7 +1,7 @@ use std::{boxed::Box, collections::VecDeque, sync::Arc}; use crate::{ - atem_lib::atem_packet::{AtemPacket, RawFields}, + atem_lib::atem_packet::RawFields, commands::device_profile::version::{DESERIALIZE_VERSION_RAW_NAME, deserialize_version}, enums::ProtocolVersion, }; diff --git a/atem-test/src/main.rs b/atem-test/src/main.rs index 72e0911..2964e10 100644 --- a/atem-test/src/main.rs +++ b/atem-test/src/main.rs @@ -36,7 +36,7 @@ async fn main() { let (atem_event_tx, atem_event_rx) = tokio::sync::mpsc::unbounded_channel(); let cancel = CancellationToken::new(); - let mut atem_socket = AtemSocket::new(socket_message_rx, atem_event_tx); + let atem_socket = AtemSocket::new(socket_message_rx, atem_event_tx); let atem = Arc::new(Atem::new(atem_socket, socket_message_tx)); let atem_thread = atem.clone();