(self, timeout=None)
| 231 | self._worker_thread.start() |
| 232 | |
| 233 | def make_stream(self, timeout=None): |
| 234 | if not self._handshake_complete.wait(timeout): |
| 235 | raise dns.exception.Timeout |
| 236 | with self._lock: |
| 237 | if self._done: |
| 238 | raise UnexpectedEOF |
| 239 | stream_id = self._connection.get_next_available_stream_id(False) |
| 240 | stream = SyncQuicStream(self, stream_id) |
| 241 | self._streams[stream_id] = stream |
| 242 | return stream |
| 243 | |
| 244 | def close_stream(self, stream_id): |
| 245 | with self._lock: |
no test coverage detected