(self)
| 853 | """ |
| 854 | |
| 855 | def __init__(self): |
| 856 | self._done = False |
| 857 | self._timeout = 2 |
| 858 | |
| 859 | if has_event_loop(): |
| 860 | self.aqueue = AsyncQueue() |
| 861 | self.queue = self.aqueue.sync_q |
| 862 | else: |
| 863 | self.queue = Queue() |
| 864 | self.aqueue = None |
| 865 | |
| 866 | def set_timeout(self, timeout: float): |
| 867 | self._timeout = timeout |
nothing calls this directly
no test coverage detected