diff --git a/aquatic_ws/src/lib/handlers.rs b/aquatic_ws/src/lib/handlers.rs
index 163658a..31e0388 100644
--- a/aquatic_ws/src/lib/handlers.rs
+++ b/aquatic_ws/src/lib/handlers.rs
@@ -105,11 +105,10 @@ async fn handle_request_stream<S>(
         };
 
         for (meta, out_message) in out_messages.drain(..) {
-            if let Err(err) =
-                out_message_senders.send_to(meta.out_message_consumer_id.0, (meta, out_message)).await
-            {
-                ::log::error!("failed sending out_message to socket worker: {:?}", err)
-            }
+            out_message_senders
+                .send_to(meta.out_message_consumer_id.0, (meta, out_message))
+                .await
+                .expect("failed sending out_message to socket worker");
         }
 
         yield_if_needed().await;
diff --git a/aquatic_ws/src/lib/network.rs b/aquatic_ws/src/lib/network.rs
index 8729ef7..fdbb561 100644
--- a/aquatic_ws/src/lib/network.rs
+++ b/aquatic_ws/src/lib/network.rs
@@ -159,11 +159,14 @@ async fn receive_out_messages(
             .borrow()
             .get(channel_out_message.0.connection_id.0)
         {
-            if let Err(err) = reference.out_message_sender.try_send(channel_out_message) {
-                ::log::error!(
-                    "Couldn't send out_message from shared channel to local receiver: {:?}",
-                    err
-                );
+            match reference.out_message_sender.try_send(channel_out_message) {
+                Ok(()) | Err(GlommioError::Closed(_)) => {},
+                Err(err) => {
+                    ::log::error!(
+                        "Couldn't send out_message from shared channel to local receiver: {:?}",
+                        err
+                    );
+                }
             }
         }
     }