(self, msg, **data)
| 1481 | return self.append_message(json_encode(data), True) |
| 1482 | |
| 1483 | def queue_message(self, msg, **data): |
| 1484 | # type: (str, Any) -> bool |
| 1485 | data["msg"] = msg |
| 1486 | return self.append_message(json_encode(data), False) |
| 1487 | |
| 1488 | def try_cleanup(self): |
| 1489 | global sockets |
no test coverage detected