(self, event, data, namespace, room=None, skip_sid=None,
callback=None, **kwargs)
| 253 | return self.sio.manager.__basic_leave_room(sid, namespace, room) |
| 254 | |
| 255 | async def _emit(self, event, data, namespace, room=None, skip_sid=None, |
| 256 | callback=None, **kwargs): |
| 257 | ret = await self.sio.manager.__emit( |
| 258 | event, data, namespace, room=room, skip_sid=skip_sid, |
| 259 | callback=callback, **kwargs) |
| 260 | if namespace != self.admin_namespace: |
| 261 | event_data = [event] + list(data) if isinstance(data, tuple) \ |
| 262 | else [event, data] |
| 263 | if not isinstance(skip_sid, list): # pragma: no branch |
| 264 | skip_sid = [skip_sid] |
| 265 | for sid, _ in self.sio.manager.get_participants(namespace, room): |
| 266 | if sid not in skip_sid: |
| 267 | await self.sio.emit('event_sent', ( |
| 268 | namespace, |
| 269 | sid, |
| 270 | event_data, |
| 271 | datetime.now(timezone.utc).isoformat(), |
| 272 | ), namespace=self.admin_namespace) |
| 273 | return ret |
| 274 | |
| 275 | async def _handle_eio_connect(self, eio_sid, environ): |
| 276 | if self.stop_stats_event is None: |
nothing calls this directly
no test coverage detected