(self, event, data, sid=None)
| 1346 | await send_socket_catch_exception(self.sockets[sid].send_bytes, message) |
| 1347 | |
| 1348 | async def send_json(self, event, data, sid=None): |
| 1349 | message = {"type": event, "data": data} |
| 1350 | |
| 1351 | if sid is None: |
| 1352 | sockets = list(self.sockets.values()) |
| 1353 | for ws in sockets: |
| 1354 | await send_socket_catch_exception(ws.send_json, message) |
| 1355 | elif sid in self.sockets: |
| 1356 | await send_socket_catch_exception(self.sockets[sid].send_json, message) |
| 1357 | |
| 1358 | def send_sync(self, event, data, sid=None): |
| 1359 | self.loop.call_soon_threadsafe( |
no test coverage detected