From 34bbc96000450afb935add13dfa5c08269d56afa Mon Sep 17 00:00:00 2001 From: JustAnotherArchivist Date: Sun, 5 Jan 2025 22:27:16 +0000 Subject: Fix asyncio.exceptions.InvalidStateError error when put_nowait is called again without the previous result getting processed --- http2irc.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/http2irc.py b/http2irc.py index f2db4e3..8037cb7 100644 --- a/http2irc.py +++ b/http2irc.py @@ -333,12 +333,12 @@ class MessageQueue: def put_nowait(self, item): self._queue.append(item) - if self._getter is not None and not self._getter.cancelled(): + if self._getter is not None and not self._getter.done() and not self._getter.cancelled(): self._getter.set_result(None) def putleft_nowait(self, *item): self._queue.extendleft(reversed(item)) - if self._getter is not None and not self._getter.cancelled(): + if self._getter is not None and not self._getter.done() and not self._getter.cancelled(): self._getter.set_result(None) def qsize(self): -- cgit v1.3.1-10-gc9f91