(self, value: _Type)
| 713 | self._pending: set[_Type] = set() |
| 714 | |
| 715 | def put(self, value: _Type) -> None: |
| 716 | if value not in self._pending: |
| 717 | self._pending.add(value) |
| 718 | self._loop.call_soon_threadsafe(self._queue.put_nowait, value) |
| 719 | |
| 720 | async def get(self) -> _Type: |
| 721 | value = await self._queue.get() |
no outgoing calls