mirror of
https://github.com/tiqi-group/pydase.git
synced 2025-04-22 09:10:01 +02:00
Merge pull request #153 from tiqi-group/feat/overwritable_sio_client_manager
adds overwritable sio client_manager
This commit is contained in:
commit
e40646c664
@ -23,6 +23,7 @@ logger = logging.getLogger(__name__)
|
|||||||
|
|
||||||
# These functions can be monkey-patched by other libraries at runtime
|
# These functions can be monkey-patched by other libraries at runtime
|
||||||
dump = pydase.utils.serialization.serializer.dump
|
dump = pydase.utils.serialization.serializer.dump
|
||||||
|
sio_client_manager = None
|
||||||
|
|
||||||
|
|
||||||
class UpdateDict(TypedDict):
|
class UpdateDict(TypedDict):
|
||||||
@ -93,9 +94,16 @@ def setup_sio_server(
|
|||||||
state_manager = observer.state_manager
|
state_manager = observer.state_manager
|
||||||
|
|
||||||
if enable_cors:
|
if enable_cors:
|
||||||
sio = socketio.AsyncServer(async_mode="aiohttp", cors_allowed_origins="*")
|
sio = socketio.AsyncServer(
|
||||||
|
async_mode="aiohttp",
|
||||||
|
cors_allowed_origins="*",
|
||||||
|
client_manager=sio_client_manager,
|
||||||
|
)
|
||||||
else:
|
else:
|
||||||
sio = socketio.AsyncServer(async_mode="aiohttp")
|
sio = socketio.AsyncServer(
|
||||||
|
async_mode="aiohttp",
|
||||||
|
client_manager=sio_client_manager,
|
||||||
|
)
|
||||||
|
|
||||||
setup_sio_events(sio, state_manager)
|
setup_sio_events(sio, state_manager)
|
||||||
setup_logging_handler(sio)
|
setup_logging_handler(sio)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user