向会话发送来自用户浏览器的事件️ :param dict event: 事件️消息
(self, event)
| 134 | return await WebIOFuture() |
| 135 | |
| 136 | def send_client_event(self, event): |
| 137 | """向会话发送来自用户浏览器的事件️ |
| 138 | |
| 139 | :param dict event: 事件️消息 |
| 140 | """ |
| 141 | coro_id = event['task_id'] |
| 142 | coro = self.coros.get(coro_id) |
| 143 | if not coro: |
| 144 | logger.error('coro not found, coro_id:%s', coro_id) |
| 145 | return |
| 146 | self._step_task(coro, event) |
| 147 | |
| 148 | def get_task_commands(self): |
| 149 | msgs = self.unhandled_task_msgs |
nothing calls this directly
no test coverage detected