From d61dfb9073c872cf755bda74f8d3ec2647e3fa5e Mon Sep 17 00:00:00 2001
From: "Timothy Z." <timothy@stremio.com>
Date: Sun, 10 May 2026 12:39:32 +0000
Subject: [PATCH] fix: keep crash-restart off the GUI message-pump thread

start() ended with rx.recv().unwrap(), so every caller blocked until
the server reported readiness. process_event runs on the NWG message
pump and is invoked when crash_notice fires; the modal_error_message
returns, start() is called, and the entire UI freezes for up to 60s
while the new stremio-runtime boots.

Return the readiness receiver from start() instead of consuming it.
build_partial keeps the synchronous wait for initial startup so the
WebView isn't attached against a not-yet-bound port. process_event
fires-and-forgets so the GUI keeps pumping; if the new runtime also
fails, the server thread will simply fire crash_notice again.

Closes #49
---
 src/stremio_app/stremio_server/server.rs | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/src/stremio_app/stremio_server/server.rs b/src/stremio_app/stremio_server/server.rs
index 01f8063..d5ddf85 100644
--- a/src/stremio_app/stremio_server/server.rs
+++ b/src/stremio_app/stremio_server/server.rs
@@ -78,13 +78,14 @@ pub struct StremioServer {
 }
 
 impl StremioServer {
-    pub fn start(&self) {
+    /// Spawn the streaming server; recv on the returned receiver to wait for readiness.
+    pub fn start(&self) -> Option<flume::Receiver<String>> {
         if self.development {
-            return;
+            return None;
         }
         if self.running.swap(true, Ordering::SeqCst) {
             eprintln!("StremioServer::start() called while a server is already running; skipping");
-            return;
+            return None;
         }
         let (tx, rx) = flume::unbounded();
         let logs = self.logs.clone();
@@ -220,8 +221,7 @@ impl StremioServer {
             sender.notice();
         });
 
-        // Wait for the server to start
-        rx.recv().unwrap();
+        Some(rx)
     }
 }
 
@@ -240,7 +240,10 @@ impl PartialUi for StremioServer {
             .parent(data.parent)
             .build(&mut data.crash_notice)
             .ok();
-        data.start();
+        // Block until ready so the WebView isn't attached against an unbound port.
+        if let Some(rx) = data.start() {
+            rx.recv().ok();
+        }
         println!("Stremio server started");
         Ok(())
     }
@@ -257,6 +260,7 @@ impl PartialUi for StremioServer {
                 "Stremio server crash log",
                 self.logs.lock().unwrap().deref(),
             );
+            // Don't block: this runs on the GUI message pump.
             self.start();
         }
     }