Fixing build issues with signature of .accept() function.

webrtc-rs · Jun 30, 2023 · 8e95ad0 · 8e95ad0
1 parent dd182ac
commit 8e95ad0
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/dtls/examples/listen/psk/listen_psk.rs b/dtls/examples/listen/psk/listen_psk.rs
@@ -77,7 +77,7 @@ async fn main() -> Result<(), Error> {
     let listener2 = Arc::clone(&listener);
     let h2 = Arc::clone(&h);
     tokio::spawn(async move {
-        while let Ok((dtls_conn, _remote_addr)) = listener2.accept().await {
+        while let Ok((dtls_conn, _ctx, _remote_addr)) = listener2.accept().await {
             // Register the connection with the chat hub
             h2.register(dtls_conn).await;
         }

diff --git a/dtls/examples/listen/selfsign/listen_selfsign.rs b/dtls/examples/listen/selfsign/listen_selfsign.rs
@@ -75,7 +75,7 @@ async fn main() -> Result<(), Error> {
     let listener2 = Arc::clone(&listener);
     let h2 = Arc::clone(&h);
     tokio::spawn(async move {
-        while let Ok((dtls_conn, _remote_addr)) = listener2.accept().await {
+        while let Ok((dtls_conn, _ctx, _remote_addr)) = listener2.accept().await {
             // Register the connection with the chat hub
             h2.register(dtls_conn).await;
         }

diff --git a/dtls/examples/listen/verify/listen_verify.rs b/dtls/examples/listen/verify/listen_verify.rs
@@ -96,7 +96,7 @@ async fn main() -> Result<(), Error> {
                 }
                 result = listener2.accept() => {
                     match result{
-                        Ok((dtls_conn, _)) => {
+                        Ok((dtls_conn, _ctx, _)) => {
                             // Register the connection with the chat hub
                             h2.register(dtls_conn).await;
                         }

diff --git a/util/src/conn/conn_udp_listener_test.rs b/util/src/conn/conn_udp_listener_test.rs
@@ -27,7 +27,7 @@ async fn pipe() -> Result<(
     let daddr = d_conn.local_addr()?;
 
     // Accept the connection
-    let (l_conn, raddr) = listener.accept().await?;
+    let (l_conn, _ctx, raddr) = listener.accept().await?;
     assert_eq!(daddr, raddr, "remote address should be match");
 
     let raddr = l_conn.remote_addr();
@@ -119,7 +119,7 @@ async fn test_listener_accept_filter() -> Result<()> {
         let listener2 = Arc::clone(&listener);
         tokio::spawn(async move {
             let (c, _raddr) = match listener2.accept().await {
-                Ok((c, raddr)) => (c, raddr),
+                Ok((c, _ctx, raddr)) => (c, raddr),
                 Err(err) => {
                     assert_eq!(Error::ErrClosedListener, err);
                     return Result::<()>::Ok(());
@@ -179,7 +179,7 @@ async fn test_listener_concurrent() -> Result<()> {
 
     let mut b = vec![0u8; 1];
     for i in 0..BACKLOG as u8 {
-        let (conn, _raddr) = listener.accept().await?;
+        let (conn, _ctx, _raddr) = listener.accept().await?;
         let n = conn.recv(&mut b).await?;
         assert_eq!(
             &b[..n],
@@ -197,7 +197,7 @@ async fn test_listener_concurrent() -> Result<()> {
     let listener2 = Arc::clone(&listener);
     tokio::spawn(async move {
         match listener2.accept().await {
-            Ok((conn, _raddr)) => {
+            Ok((conn, _ctx, _raddr)) => {
                 conn.close().await?;
             }
             Err(err) => {