Streams-R-Us
/
atem-connection-rs
3
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

cargo fix

This commit is contained in:
Sam W 2025-06-20 13:51:07 +01:00
parent c9b3879b6c
commit 5fb847aec6
4 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
atem-connection-rs/src/atem_lib/atem_socket.rs
View File

@ -18,11 +18,8 @@ use tokio::{
}; };
use crate::{ use crate::{
atem_lib::atem_packet::{self, AtemPacket, COMMAND_CONNECT_HELLO}, atem_lib::atem_packet::{AtemPacket, COMMAND_CONNECT_HELLO},
commands::{ commands::command_base::{BasicWritableCommand, DeserializedCommand},
command_base::{BasicWritableCommand, DeserializedCommand},
parse_commands::deserialize_commands,
},
enums::ProtocolVersion, enums::ProtocolVersion,
}; };

2
atem-connection-rs/src/commands/command_base.rs
View File

@ -1,5 +1,5 @@
use std::{ 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, vec::Vec,
}; };

2
atem-connection-rs/src/commands/parse_commands.rs
View File

@ -1,7 +1,7 @@
use std::{boxed::Box, collections::VecDeque, sync::Arc}; use std::{boxed::Box, collections::VecDeque, sync::Arc};
use crate::{ use crate::{
atem_lib::atem_packet::{AtemPacket, RawFields}, atem_lib::atem_packet::RawFields,
commands::device_profile::version::{DESERIALIZE_VERSION_RAW_NAME, deserialize_version}, commands::device_profile::version::{DESERIALIZE_VERSION_RAW_NAME, deserialize_version},
enums::ProtocolVersion, enums::ProtocolVersion,
}; };

2
atem-test/src/main.rs
View File

@ -36,7 +36,7 @@ async fn main() {
let (atem_event_tx, atem_event_rx) = tokio::sync::mpsc::unbounded_channel(); let (atem_event_tx, atem_event_rx) = tokio::sync::mpsc::unbounded_channel();
let cancel = CancellationToken::new(); 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 = Arc::new(Atem::new(atem_socket, socket_message_tx));
let atem_thread = atem.clone(); let atem_thread = atem.clone();