propagate errors from proxied sockets

zeromq · Dec 30, 2024 · de70ebe · de70ebe
1 parent ab55c51
commit de70ebe
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -357,8 +357,8 @@ pub async fn proxy<Frontend: SocketSend + SocketRecv, Backend: SocketSend + Sock
                         }
                         backend.send(message).await?;
                     }
-                    Err(_) => {
-                        todo!()
+                    Err(e) => {
+                        return Err(e);
                     }
                 }
             },
@@ -370,8 +370,8 @@ pub async fn proxy<Frontend: SocketSend + SocketRecv, Backend: SocketSend + Sock
                         }
                         frontend.send(message).await?;
                     }
-                    Err(_) => {
-                        todo!()
+                    Err(e) => {
+                        return Err(e);
                     }
                 }
             }