(self, block: bool = True, timeout: Optional[float] = None)
| 303 | raise Empty() from err |
| 304 | |
| 305 | def get(self, block: bool = True, timeout: Optional[float] = None) -> _T: |
| 306 | if not block: |
| 307 | return self.get_nowait() |
| 308 | |
| 309 | try: |
| 310 | if timeout is not None: |
| 311 | return self.await_( |
| 312 | asyncio.wait_for(self._queue.get(), timeout) |
| 313 | ) |
| 314 | else: |
| 315 | return self.await_(self._queue.get()) |
| 316 | except (asyncio.QueueEmpty, asyncio.TimeoutError) as err: |
| 317 | raise Empty() from err |
| 318 | |
| 319 | |
| 320 | class FallbackAsyncAdaptedQueue(AsyncAdaptedQueue[_T]): |
nothing calls this directly
no test coverage detected