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();