(self, event, data, sid=None)
| 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( |
| 1360 | self.messages.put_nowait, (event, data, sid)) |
| 1361 | |
| 1362 | def queue_updated(self): |
| 1363 | self.send_sync("status", { "status": self.get_queue_info() }) |
no outgoing calls
no test coverage detected