触发Backend on_session_close callback
(self)
| 164 | return self.unhandled_task_msgs.get() |
| 165 | |
| 166 | def _trigger_close_event(self): |
| 167 | """触发Backend on_session_close callback""" |
| 168 | if self.closed(): |
| 169 | return |
| 170 | if self._loop: |
| 171 | self._loop.call_soon_threadsafe(self._on_session_close) |
| 172 | else: |
| 173 | self._on_session_close() |
| 174 | |
| 175 | def _cleanup(self, nonblock=False): |
| 176 | # reset the reference, to avoid circular reference |