From 51118fee63ccf6065e12ae6cbeeafd2361423e8a Mon Sep 17 00:00:00 2001 From: Nell Date: Tue, 15 Jul 2025 17:26:16 +0200 Subject: [PATCH] Init --- src/app/app.rs | 2 +- src/domain/event.rs | 1 - src/network/udp.rs | 3 +-- src/runtime/dispatcher.rs | 2 +- 4 files changed, 3 insertions(+), 5 deletions(-) diff --git a/src/app/app.rs b/src/app/app.rs index b682ee5..e9af63c 100644 --- a/src/app/app.rs +++ b/src/app/app.rs @@ -24,7 +24,7 @@ impl App { pub async fn new() -> Self { let (event_bus, event_rx) = EventBus::new(); - let udp_server = UdpServer::new(event_bus.clone(), "127.0.0.1:5000").await; + let udp_server = UdpServer::new(event_bus.clone(), "0.0.0.0:5000").await; let client_manager = ClientManager::new(); let dispatcher = Dispatcher::new(event_bus.clone(), udp_server.clone(), client_manager.clone()).await; diff --git a/src/domain/event.rs b/src/domain/event.rs index ec9a599..1b6e15f 100644 --- a/src/domain/event.rs +++ b/src/domain/event.rs @@ -1,4 +1,3 @@ -use std::net::SocketAddr; use tokio::sync::mpsc; use crate::network::protocol::{UDPMessage}; diff --git a/src/network/udp.rs b/src/network/udp.rs index dfb05f1..e29c599 100644 --- a/src/network/udp.rs +++ b/src/network/udp.rs @@ -1,6 +1,5 @@ use tokio::net::UdpSocket; use std::error::Error; -use std::net::SocketAddr; use std::sync::Arc; use tokio::task::AbortHandle; use crate::domain::event::{Event, EventBus}; @@ -67,7 +66,7 @@ impl UdpServer { pub async fn send_udp_message(&self, message: &UDPMessage) -> bool { match self.socket.send_to(&message.to_bytes(), message.address()).await { - Ok(size) => { + Ok(_size) => { self.event_bus.emit(Event::UdpOut(message.clone())).await; true } diff --git a/src/runtime/dispatcher.rs b/src/runtime/dispatcher.rs index 8d8cabd..1925777 100644 --- a/src/runtime/dispatcher.rs +++ b/src/runtime/dispatcher.rs @@ -24,7 +24,7 @@ impl Dispatcher { } pub async fn start(&self, mut receiver: mpsc::Receiver) { - let (udp_in_abort_handle, udp_in_sender) = self.udp_in_handler().await; + let (_udp_in_abort_handle, udp_in_sender) = self.udp_in_handler().await; while let Some(event) = receiver.recv().await { match event {