commit 8ebbeec288b849c7944af925d1d00814a1ef17c7 Author: Illia Volochii illia.volochii@gmail.com Date: Thu May 21 22:39:52 2020 +0300
Use `asyncio.Queue.put_nowait` instead of `put` that needs awaiting --- stem/control.py | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-)
diff --git a/stem/control.py b/stem/control.py index 84f8f39b..be7ab6c6 100644 --- a/stem/control.py +++ b/stem/control.py @@ -946,18 +946,18 @@ class BaseController(_BaseControllerSocketMixin):
if control_message.content()[-1][0] == '650': # asynchronous message, adds to the event queue and wakes up its handler - await self._event_queue.put(control_message) + self._event_queue.put_nowait(control_message) self._event_notice.set() else: # response to a msg() call - await self._reply_queue.put(control_message) + self._reply_queue.put_nowait(control_message) except stem.ControllerError as exc: # Assume that all exceptions belong to the reader. This isn't always # true, but the msg() call can do a better job of sorting it out. # # Be aware that the msg() method relies on this to unblock callers.
- await self._reply_queue.put(exc) + self._reply_queue.put_nowait(exc)
async def _event_loop(self) -> None: """ @@ -2045,11 +2045,11 @@ class AsyncController(BaseController): start_time = time.time()
if await_result: - async def hs_desc_listener(event: stem.response.events.Event) -> None: - await hs_desc_queue.put(event) + def hs_desc_listener(event: stem.response.events.Event) -> None: + hs_desc_queue.put_nowait(event)
- async def hs_desc_content_listener(event: stem.response.events.Event) -> None: - await hs_desc_content_queue.put(event) + def hs_desc_content_listener(event: stem.response.events.Event) -> None: + hs_desc_content_queue.put_nowait(event)
await asyncio.gather( self.add_event_listener(hs_desc_listener, EventType.HS_DESC), @@ -2926,8 +2926,8 @@ class AsyncController(BaseController): start_time = time.time()
if await_publication: - async def hs_desc_listener(event: stem.response.events.Event) -> None: - await hs_desc_queue.put(event) + def hs_desc_listener(event: stem.response.events.Event) -> None: + hs_desc_queue.put_nowait(event)
await self.add_event_listener(hs_desc_listener, EventType.HS_DESC)
@@ -3458,8 +3458,8 @@ class AsyncController(BaseController): start_time = time.time()
if await_build: - async def circ_listener(event: stem.response.events.Event) -> None: - await circ_queue.put(event) + def circ_listener(event: stem.response.events.Event) -> None: + circ_queue.put_nowait(event)
await self.add_event_listener(circ_listener, EventType.CIRC)