invoking future for ws push

kinode-dao · Dec 22, 2023 · 2c01800 · 2c01800
1 parent 326e68d
commit 2c01800
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/http/server.rs b/src/http/server.rs
@@ -650,6 +650,7 @@ async fn maintain_websocket(
             read = read_stream.next() => {
                 match read {
                     Some(Ok(msg)) => {
+
                         let _ = send_to_loop.send(KernelMessage {
                             id: rand::random(),
                             source: Address {
@@ -675,7 +676,8 @@ async fn maintain_websocket(
                                 bytes: msg.into_bytes(),
                             }),
                             signed_capabilities: None,
-                        });
+                        }).await;
+
                     }
                     _ => {
                         websocket_close(channel_id, app.clone(), &ws_senders, &send_to_loop).await;