Merge pull request #1 from devamin/feat/pass-manager-kwargs-from-namespace

devamin · web-flow · commit 3a038f477570 · 2022-12-22T21:41:50.000+01:00
Feat/pass manager kwargs from namespace
diff --git a/src/socketio/asyncio_namespace.py b/src/socketio/asyncio_namespace.py
@@ -42,7 +42,7 @@ async def trigger_event(self, event, *args):
             return ret
 
     async def emit(self, event, data=None, to=None, room=None, skip_sid=None,
-                   namespace=None, callback=None):
+                   namespace=None, callback=None, **kwargs):
         """Emit a custom event to one or more connected clients.
 
         The only difference with the :func:`socketio.Server.emit` method is
@@ -54,7 +54,7 @@ async def emit(self, event, data=None, to=None, room=None, skip_sid=None,
         return await self.server.emit(event, data=data, to=to, room=room,
                                       skip_sid=skip_sid,
                                       namespace=namespace or self.namespace,
-                                      callback=callback)
+                                      callback=callback, **kwargs)
 
     async def send(self, data, to=None, room=None, skip_sid=None,
                    namespace=None, callback=None):
diff --git a/src/socketio/namespace.py b/src/socketio/namespace.py
@@ -38,7 +38,7 @@ def _set_server(self, server):
         self.server = server
 
     def emit(self, event, data=None, to=None, room=None, skip_sid=None,
-             namespace=None, callback=None):
+             namespace=None, callback=None, **kwargs):
         """Emit a custom event to one or more connected clients.
 
         The only difference with the :func:`socketio.Server.emit` method is
@@ -48,7 +48,7 @@ def emit(self, event, data=None, to=None, room=None, skip_sid=None,
         return self.server.emit(event, data=data, to=to, room=room,
                                 skip_sid=skip_sid,
                                 namespace=namespace or self.namespace,
-                                callback=callback)
+                                callback=callback, **kwargs)
 
     def send(self, data, to=None, room=None, skip_sid=None, namespace=None,
              callback=None):
