(self)
| 246 | super().close_stream(stream_id) |
| 247 | |
| 248 | def close(self): |
| 249 | with self._lock: |
| 250 | if self._closed: |
| 251 | return |
| 252 | if self._manager is not None: |
| 253 | self._manager.closed(self._peer[0], self._peer[1]) |
| 254 | self._closed = True |
| 255 | self._connection.close() |
| 256 | self._send_wakeup.send(b"\x01") |
| 257 | if self._worker_thread is not None: |
| 258 | self._worker_thread.join() |
| 259 | |
| 260 | |
| 261 | class SyncQuicManager(BaseQuicManager): |