diff --git a/aquatic_ws/src/workers/socket.rs b/aquatic_ws/src/workers/socket.rs
index 81190c5..2e6ebb6 100644
--- a/aquatic_ws/src/workers/socket.rs
+++ b/aquatic_ws/src/workers/socket.rs
@@ -430,7 +430,9 @@ async fn run_stream_agnostic_connection<
     .unwrap()
     .detach();
 
-    race(reader_handle, writer_handle).await.unwrap()
+    race(reader_handle, writer_handle)
+        .await
+        .expect("reader/writer task should not be closed")
 }
 
 struct ConnectionReader<S> {