(self, connection, stream_id)
| 30 | |
| 31 | class SyncQuicStream(BaseQuicStream): |
| 32 | def __init__(self, connection, stream_id): |
| 33 | super().__init__(connection, stream_id) |
| 34 | self._wake_up = threading.Condition() |
| 35 | self._lock = threading.Lock() |
| 36 | |
| 37 | def wait_for(self, amount, expiration): |
| 38 | while True: |