YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_ws: in request workers, await out message channel space

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-02 11:58:10 +01:00
parent 2f5e023fd7
commit 6140596d7e
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
aquatic_ws/src/lib/handlers.rs
View file

@ -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)
}