Update lib.rs (#130)

Fix #129
2 years ago · 48f527ad81
1 changed files with 1 additions and 1 deletions
--- a/src/lib.rs
+++ b/src/lib.rs
@ -134,7 +134,7 @@ async fn create_udp_stream(socket_queue: &Option<Arc<SocketQueue>>, peer: Socket
        Some(queue) => {
            let socket = queue.recv_udp(peer.ip().into()).await?;
            socket.connect(peer).await?;
-            UdpStream::from_tokio(socket).await
+            UdpStream::from_tokio(socket, peer).await
        }
    }
 }