向会话发送来自协程内的消息 :param dict command: 消息
(self, command)
| 119 | self.close() |
| 120 | |
| 121 | def send_task_command(self, command): |
| 122 | """向会话发送来自协程内的消息 |
| 123 | |
| 124 | :param dict command: 消息 |
| 125 | """ |
| 126 | if self.closed(): |
| 127 | raise SessionClosedException() |
| 128 | self.unhandled_task_msgs.append(command) |
| 129 | self._on_task_command(self) |
| 130 | |
| 131 | async def next_client_event(self): |
| 132 | # 函数开始不需要判断 self.closed() |
no test coverage detected