diff --git a/src/acars_router_servers/tcp/outputs/tcp_sender_server.rs b/src/acars_router_servers/tcp/outputs/tcp_sender_server.rs index 2e64393a..7e3e4796 100644 --- a/src/acars_router_servers/tcp/outputs/tcp_sender_server.rs +++ b/src/acars_router_servers/tcp/outputs/tcp_sender_server.rs @@ -15,7 +15,9 @@ use tokio::net::TcpStream; // TODO: The error and info messages kicked out by StubbornIO are kinda...useless. // It doesn't include things like host, port, etc. -// Can we fix that? +// I created an issue on the crate. I'm hoping to get a better error message. If it's not +// Fixed relatively soon I'll attempt a patch of the crate. +// https://github.com/craftytrickster/stubborn-io/issues/23 impl SenderServer> { pub async fn send_message(mut self) { diff --git a/src/acars_router_servers/udp/inputs/udp_listener_server.rs b/src/acars_router_servers/udp/inputs/udp_listener_server.rs index a1ea4f23..e1fd4083 100644 --- a/src/acars_router_servers/udp/inputs/udp_listener_server.rs +++ b/src/acars_router_servers/udp/inputs/udp_listener_server.rs @@ -68,9 +68,9 @@ impl UDPListenerServer { let split_messages_by_newline: Vec<&str> = msg_string.split_terminator('\n').collect(); - for msg_by_lineline in split_messages_by_newline { + for msg_by_newline in split_messages_by_newline { let split_messages_by_brackets: Vec<&str> = - msg_by_lineline.split_terminator("}{").collect(); + msg_by_newline.split_terminator("}{").collect(); // First attempt to deserialise just the new message for (count, msg_by_brackets) in split_messages_by_brackets.iter().enumerate()