Squashed commit of the following:

commit 8720a6c6c6ef08ae5a134f544338393ba969f505
Author: Feodor Fitsner <[email protected]>
Date:   Wed Oct 25 12:29:04 2023 -0700

    Cleanup

commit d312eeb8f9661ee4e012e63c053989315e6bed7a
Author: Feodor Fitsner <[email protected]>
Date:   Wed Oct 25 11:22:56 2023 -0700

    Handler global

commit bce5ccf680c063dd92bdce249383a88f60018895
Author: Feodor Fitsner <[email protected]>
Date:   Wed Oct 25 11:13:45 2023 -0700

    blocking connection

Author: FeodorFitsner

sdk/python/packages/flet-runtime/src/flet_runtime/app.py

@@ -151,20 +151,8 @@ def __app_sync(
     else:
         logger.info(f"App URL: {conn.page_url}")
 
-    terminate = threading.Event()
-
-    def exit_gracefully(signum, frame):
-        logger.debug("Gracefully terminating Flet app...")
-        terminate.set()
-
-    signal.signal(signal.SIGINT, exit_gracefully)
-    signal.signal(signal.SIGTERM, exit_gracefully)
-
     logger.info("Connected to Flet app and handling user sessions...")
 
-    fvp = None
-    pid_file = None
-
     if (
         (
             view == AppView.FLET_APP
@@ -182,20 +170,33 @@ def exit_gracefully(signum, frame):
         )
         try:
             fvp.wait()
-        except Exception as e:
+        except:
             pass
-    else:
+
+        close_flet_view(pid_file)
+        conn.close()
+
+    elif not is_embedded():
         if view == AppView.WEB_BROWSER and url_prefix is None:
             open_in_browser(conn.page_url)
+
+        terminate = threading.Event()
+
+        def exit_gracefully(signum, frame):
+            logger.debug("Gracefully terminating Flet app...")
+            terminate.set()
+
+        signal.signal(signal.SIGINT, exit_gracefully)
+        signal.signal(signal.SIGTERM, exit_gracefully)
+
         try:
             while True:
                 if terminate.wait(1):
                     break
         except KeyboardInterrupt:
             pass
 
-    conn.close()
-    close_flet_view(pid_file)
+        conn.close()
 
 
 async def app_async(
@@ -251,9 +252,6 @@ def exit_gracefully(signum, frame):
 
     logger.info("Connected to Flet app and handling user sessions...")
 
-    fvp = None
-    pid_file = None
-
     if (
         (
             view == AppView.FLET_APP
@@ -271,18 +269,22 @@ def exit_gracefully(signum, frame):
         )
         try:
             await fvp.wait()
-        except Exception as e:
+        except:
             pass
-    else:
+
+        close_flet_view(pid_file)
+        await conn.close()
+
+    elif not is_embedded():
         if view == AppView.WEB_BROWSER and url_prefix is None:
             open_in_browser(conn.page_url)
+
         try:
             await terminate.wait()
         except KeyboardInterrupt:
             pass
 
-    await conn.close()
-    close_flet_view(pid_file)
+        await conn.close()
 
 
 def close_flet_view(pid_file):
@@ -370,6 +372,7 @@ def on_session_created(conn, session_data):
             uds_path,
             on_event=on_event,
             on_session_created=on_session_created,
+            blocking=is_embedded(),
         )
     else:
         assert server
@@ -458,6 +461,7 @@ async def on_session_created(session_data):
             uds_path,
             on_event=on_event,
             on_session_created=on_session_created,
+            blocking=is_embedded(),
         )
     else:
         assert server

sdk/python/packages/flet-runtime/src/flet_runtime/async_local_socket_connection.py

@@ -31,13 +31,15 @@ def __init__(
         uds_path: Optional[str] = None,
         on_event=None,
         on_session_created=None,
+        blocking=False,
     ):
         super().__init__()
         self.__send_queue = asyncio.Queue(1)
         self.__port = port
         self.__uds_path = uds_path
         self.__on_event = on_event
         self.__on_session_created = on_session_created
+        self.__blocking = blocking
 
     async def connect(self):
         self.__connected = False
@@ -48,7 +50,6 @@ async def connect(self):
             self.page_url = f"tcp://{host}:{port}"
             logger.info(f"Starting up TCP server on {host}:{port}")
             server = await asyncio.start_server(self.handle_connection, host, port)
-            self.__server = asyncio.create_task(server.serve_forever())
         else:
             # UDS
             if not self.__uds_path:
@@ -62,6 +63,11 @@ async def connect(self):
             server = await asyncio.start_unix_server(
                 self.handle_connection, self.__uds_path
             )
+
+        if self.__blocking:
+            self.__server = None
+            await server.serve_forever()
+        else:
             self.__server = asyncio.create_task(server.serve_forever())
 
     async def handle_connection(

sdk/python/packages/flet-runtime/src/flet_runtime/sync_local_socket_connection.py

@@ -32,12 +32,14 @@ def __init__(
         uds_path: Optional[str] = None,
         on_event=None,
         on_session_created=None,
+        blocking=False,
     ):
         super().__init__()
         self.__port = port
         self.__uds_path = uds_path
         self.__on_event = on_event
         self.__on_session_created = on_session_created
+        self.__blocking = blocking
 
     def connect(self):
         if is_windows() or self.__port > 0:
@@ -66,8 +68,11 @@ def connect(self):
         self.__sock.listen(1)
 
         # start connect loop
-        th = threading.Thread(target=self.__connection_loop, args=(), daemon=True)
-        th.start()
+        if self.__blocking:
+            self.__connection_loop()
+        else:
+            th = threading.Thread(target=self.__connection_loop, args=(), daemon=True)
+            th.start()
 
     def __on_message(self, data):
         logger.debug(f"_on_message: {data}")