From 6140596d7e41fb663124d901379f95ab2ad87c53 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Tue, 2 Nov 2021 11:58:10 +0100
Subject: [PATCH] aquatic_ws: in request workers, await out message channel
 space

---
 aquatic_ws/src/lib/handlers.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/aquatic_ws/src/lib/handlers.rs b/aquatic_ws/src/lib/handlers.rs
index bfb337d..163658a 100644
--- a/aquatic_ws/src/lib/handlers.rs
+++ b/aquatic_ws/src/lib/handlers.rs
@@ -106,7 +106,7 @@ async fn handle_request_stream<S>(
 
         for (meta, out_message) in out_messages.drain(..) {
             if let Err(err) =
-                out_message_senders.try_send_to(meta.out_message_consumer_id.0, (meta, out_message))
+                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)
             }