(self)
| 33 | pass |
| 34 | |
| 35 | async def get(self) -> QueueType: |
| 36 | if not self.ready_event.is_set(): |
| 37 | await self.ready_event.wait() |
| 38 | value = self.values.popleft() |
| 39 | if not self.values: |
| 40 | self.ready_event.clear() |
| 41 | return value |
| 42 | |
| 43 | def get_nowait(self) -> QueueType: |
| 44 | if not self.values: |