chore: bump rtp to v0.0.38, udp_listener to v0.0.9

Cargo.toml

@@ -40,7 +40,7 @@ once_cell = "1"
 pin-project-lite = "0.2"
 rand = "0.8"
 regex = "1"
-rtp = { git = "https://github.com/Banyc/rtp.git", tag = "v0.0.36" }
+rtp = { git = "https://github.com/Banyc/rtp.git", tag = "v0.0.38" }
 scopeguard = "1"
 serde = "1"
 serde_json = "1"
@@ -60,7 +60,7 @@ tokio_throughput = { git = "https://github.com/Banyc/tokio_throughput.git", rev
 toml = "0.8"
 tracing = "0.1"
 tracing-subscriber = "0.3"
-udp_listener = { git = "https://github.com/Banyc/udp_listener.git", tag = "v0.0.8" }
+udp_listener = { git = "https://github.com/Banyc/udp_listener.git", tag = "v0.0.9" }
 
 [profile.profiling]
 inherits = "release"

protocol/src/stream/streams/rtp.rs

@@ -9,6 +9,7 @@ use tokio::{
 use tracing::{error, info, instrument, trace, warn};
 
 use common::{
+    addr::any_addr,
     error::AnyResult,
     loading,
     stream::{connect::StreamConnect, IoAddr, IoStream, StreamServerHook},
@@ -84,7 +85,7 @@ where
                     };
                     let stream = AddressedRtpStream {
                         read: accepted.read.into_async_read(),
-                        write: accepted.write.into_async_write(true),
+                        write: accepted.write.into_async_write(),
                         local_addr: self.listener.local_addr(),
                         peer_addr: accepted.peer_addr,
                     };
@@ -125,10 +126,11 @@ pub struct RtpConnector;
 impl StreamConnect for RtpConnector {
     type Connection = Connection;
     async fn connect(&self, addr: SocketAddr) -> io::Result<Connection> {
-        let connected = rtp::udp::connect_without_handshake(addr, None).await?;
+        let connected =
+            rtp::udp::connect_without_handshake(any_addr(&addr.ip()), addr, None).await?;
         let stream = AddressedRtpStream {
             read: connected.read.into_async_read(),
-            write: connected.write.into_async_write(true),
+            write: connected.write.into_async_write(),
             local_addr: connected.local_addr,
             peer_addr: connected.peer_addr,
         };