From 28887f06f1ca4f616f03f90e3b6bd5a8ceb58897 Mon Sep 17 00:00:00 2001 From: Omer Yacine Date: Thu, 10 Oct 2024 00:14:43 +0300 Subject: [PATCH] Update rpc.rs Add a todo --- mm2src/mm2_main/src/rpc.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/mm2src/mm2_main/src/rpc.rs b/mm2src/mm2_main/src/rpc.rs index 85b61db612..2ccd1ee0d2 100644 --- a/mm2src/mm2_main/src/rpc.rs +++ b/mm2src/mm2_main/src/rpc.rs @@ -344,6 +344,7 @@ pub extern "C" fn spawn_rpc(ctx_h: u32) { let (tx, rx) = oneshot::channel(); // We execute the request in a separate task to avoid it being left uncompleted if the client disconnects. // So what's inside the spawn here will complete till completion (or panic). + // TODO: Figure out whether we could configure hyper to follow such a behavior. common::executor::spawn(async move { if is_event_stream_enabled && req.uri().path() == SSE_ENDPOINT { tx.send(handle_sse(req, ctx_h).await).ok();