Simplify

rust-bitcoin · May 16, 2024 · 95a44cf · 95a44cf
1 parent e10c969
commit 95a44cf
Showing 1 changed file with 16 additions and 30 deletions.
diff --git a/proxy/src/bin/v1.rs b/proxy/src/bin/v1.rs
@@ -23,41 +23,27 @@ async fn proxy_conn(client: TcpStream) -> Result<(), bip324_proxy::Error> {
 
     tokio::spawn(async move {
         loop {
-            let res = read_v1(&mut client_reader).await;
-            match res {
-                Ok(msg) => {
-                    println!(
-                        "Read {} message from client, writing to remote.",
-                        msg.command()
-                    );
-                    write_v1(&mut remote_writer, msg)
-                        .await
-                        .expect("write to remote");
-                }
-                Err(e) => {
-                    panic!("unable to read from client {}", e);
-                }
-            }
+            let msg = read_v1(&mut client_reader).await.expect("read from client");
+            println!(
+                "Read {} message from client, writing to remote.",
+                msg.command()
+            );
+            write_v1(&mut remote_writer, msg)
+                .await
+                .expect("write to remote");
         }
     });
 
     tokio::spawn(async move {
         loop {
-            let res = read_v1(&mut remote_reader).await;
-            match res {
-                Ok(msg) => {
-                    println!(
-                        "Read {} message from remote, writing to client.",
-                        msg.command()
-                    );
-                    write_v1(&mut client_writer, msg)
-                        .await
-                        .expect("write to client");
-                }
-                Err(e) => {
-                    panic!("unable to read from remote {}", e);
-                }
-            }
+            let msg = read_v1(&mut remote_reader).await.expect("read from remote");
+            println!(
+                "Read {} message from remote, writing to client.",
+                msg.command()
+            );
+            write_v1(&mut client_writer, msg)
+                .await
+                .expect("write to client");
         }
     });