diff options
| author |  JustAnotherArchivist | 2025-01-05 22:27:16 +0000 |
|---|---|---|
| committer | JustAnotherArchivist | 2025-01-05 22:27:16 +0000 |
| commit | 34bbc96000450afb935add13dfa5c08269d56afa (patch) | |
| tree | 698b477083c1ba7d7cfa942fbd7e2d5b01794a12 /http2irc.py | |
| parent | Fix disconnects when there is a large send queue (diff) | |
| signature | ||
Fix asyncio.exceptions.InvalidStateError error when put_nowait is called again without the previous result getting processed
Diffstat (limited to 'http2irc.py')
| -rw-r--r-- | http2irc.py | 4 |
1 files 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): |