Start Flet socket server transport and return active connection object. Args: port: TCP port to bind (`0` lets OS choose). main: User app entry handler. before_main: Optional hook called before `main`. blocking: Whether server should run in blocking mode.
(
port: int = 0,
main: Optional[AppCallable] = None,
before_main: Optional[AppCallable] = None,
blocking: bool = False,
)
| 363 | |
| 364 | |
| 365 | async def __run_socket_server( |
| 366 | port: int = 0, |
| 367 | main: Optional[AppCallable] = None, |
| 368 | before_main: Optional[AppCallable] = None, |
| 369 | blocking: bool = False, |
| 370 | ): |
| 371 | """ |
| 372 | Start Flet socket server transport and return active connection object. |
| 373 | |
| 374 | Args: |
| 375 | port: TCP port to bind (`0` lets OS choose). |
| 376 | main: User app entry handler. |
| 377 | before_main: Optional hook called before `main`. |
| 378 | blocking: Whether server should run in blocking mode. |
| 379 | |
| 380 | Returns: |
| 381 | Started socket-server connection instance. |
| 382 | """ |
| 383 | |
| 384 | from flet.messaging.flet_socket_server import FletSocketServer |
| 385 | |
| 386 | uds_path = os.getenv("FLET_SERVER_UDS_PATH") |
| 387 | |
| 388 | executor = concurrent.futures.ThreadPoolExecutor() |
| 389 | |
| 390 | conn = FletSocketServer( |
| 391 | loop=asyncio.get_running_loop(), |
| 392 | port=port, |
| 393 | uds_path=uds_path, |
| 394 | on_session_created=__get_on_session_created(main), |
| 395 | before_main=before_main, |
| 396 | blocking=blocking, |
| 397 | executor=executor, |
| 398 | ) |
| 399 | await conn.start() |
| 400 | return conn |
| 401 | |
| 402 | |
| 403 | async def __run_web_server( |
no test coverage detected