fix warn

packages/services/virtual_socket/src/handler.rs

@@ -22,11 +22,8 @@ impl<BE, HE> ConnectionHandler<BE, HE> for VirtualSocketHandler {
 
     /// Called when an event occurs on the connection.
     fn on_event(&mut self, _ctx: &ConnectionContext, _now_ms: u64, event: ConnectionEvent) {
-        match event {
-            ConnectionEvent::Msg(msg) => {
-                self.internal.on_incomming(msg);
-            }
-            _ => {}
+        if let ConnectionEvent::Msg(msg) = event {
+            self.internal.on_incomming(msg);
         }
     }
 

packages/services/virtual_socket/src/vnet.rs

@@ -39,6 +39,6 @@ impl VirtualNet {
     }
 
     pub fn create_udp_socket(&self, port: u16, buffer_size: usize) -> Result<VirtualUdpSocket, VirtualNetError> {
-        Ok(VirtualUdpSocket::new(self.internal.clone(), port, buffer_size)?)
+        VirtualUdpSocket::new(self.internal.clone(), port, buffer_size)
     }
 }

packages/services/virtual_socket/src/vnet/internal.rs

@@ -56,7 +56,7 @@ impl VirtualNetInternal {
     pub fn unregister_socket(&self, port: u16) {
         let mut sockets = self.sockets.write();
         let mut ports = self.ports.write();
-        if let Some(_) = sockets.remove(&port) {
+        if sockets.remove(&port).is_some() {
             log::info!("[VirtualNetInternal] Unregister socket on port {}", port);
             ports.push(port);
         }

packages/transports/udp/src/transport.rs

@@ -71,14 +71,14 @@ impl UdpTransport {
                 if let Ok((size, addr)) = async_socket.recv_from(&mut buf).await {
                     let current_ms = timer.now_ms();
                     if let Some(msg_tx) = connection.get_mut(&addr) {
-                        msg_tx.0.try_send((buf, size));
+                        let _ = msg_tx.0.try_send((buf, size));
                         msg_tx.1 = current_ms;
                     } else {
                         log::info!("[UdpTransport] on new connection from {}", addr);
                         conn_id_seed += 1;
                         let conn_id = ConnId::from_in(UDP_PROTOCOL_ID, conn_id_seed);
                         let (msg_tx, msg_rx) = async_std::channel::bounded(1024);
-                        msg_tx.try_send((buf, size));
+                        let _ = msg_tx.try_send((buf, size));
                         connection.insert(addr, (msg_tx, current_ms));
                         let socket = socket.clone();
                         let async_socket = async_socket.clone();