From 024eb3df4a0786a92033baea123aa779998cdc28 Mon Sep 17 00:00:00 2001
From: Max Audron <me@audron.dev>
Date: Sun, 22 Feb 2026 14:06:16 +0100
Subject: NetworkList and signalproxy objects error handling

---
 src/frame/mod.rs   |  4 ++--
 src/frame/tests.rs | 12 ++++++------
 2 files changed, 8 insertions(+), 8 deletions(-)

(limited to 'src/frame')

diff --git a/src/frame/mod.rs b/src/frame/mod.rs
index 1c2f859..75d57ff 100644
--- a/src/frame/mod.rs
+++ b/src/frame/mod.rs
@@ -162,7 +162,7 @@ impl Decoder for QuasselCodec {
             let after_in = self.decomp.total_in();
             let after_out = self.decomp.total_out();
 
-            let len = (after_out - before_out).try_into().unwrap();
+            let len = (after_out - before_out).try_into()?;
 
             // Reserve length of uncompressed stream
             // and put bytes into there
@@ -233,7 +233,7 @@ impl Encoder<Vec<u8>> for QuasselCodec {
             let after_in = self.comp.total_in();
             let after_out = self.comp.total_out();
 
-            cbuf.truncate((after_out - before_out).try_into().unwrap());
+            cbuf.truncate((after_out - before_out).try_into()?);
             *dst = BytesMut::from(&cbuf[..]);
         } else {
             *dst = buf.clone();
diff --git a/src/frame/tests.rs b/src/frame/tests.rs
index 4ae5e1a..69c27a6 100644
--- a/src/frame/tests.rs
+++ b/src/frame/tests.rs
@@ -111,7 +111,7 @@ fn quasselcodec_read_oversized() {
     );
 
     tokio_test::block_on(async move {
-        let res = io.next().await.unwrap().map_err(|e| e.kind());
+        let res = io.next().await?.map_err(|e| e.kind());
         let want = Err(std::io::ErrorKind::InvalidData);
 
         assert_eq!(want, res);
@@ -170,7 +170,7 @@ fn write_single_frame() {
     );
 
     tokio_test::block_on(async move {
-        io.send(b"abcdefghi".to_vec()).await.unwrap();
+        io.send(b"abcdefghi".to_vec()).await?;
     });
 }
 
@@ -188,9 +188,9 @@ fn write_multi_frame() {
     );
 
     tokio_test::block_on(async move {
-        io.send(b"abcdefghi".to_vec()).await.unwrap();
-        io.send(b"123".to_vec()).await.unwrap();
-        io.send(b"hello world".to_vec()).await.unwrap();
+        io.send(b"abcdefghi".to_vec()).await?;
+        io.send(b"123".to_vec()).await?;
+        io.send(b"hello world".to_vec()).await?;
     });
 }
 
@@ -206,6 +206,6 @@ fn write_single_frame_compressed() {
     );
 
     tokio_test::block_on(async move {
-        io.send(b"abcdefghi".to_vec()).await.unwrap();
+        io.send(b"abcdefghi".to_vec()).await?;
     });
 }
-- 
cgit v1.2.3