From 5077db0a6b172f0daf59392f23efdc23f39a5bcb Mon Sep 17 00:00:00 2001 From: JustAnotherArchivist Date: Mon, 16 Dec 2019 00:40:17 +0000 Subject: Fix InvalidStateError in MessageQueue when the IRC server closes the connection --- http2irc.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/http2irc.py b/http2irc.py index 7f76c67..39d1ace 100644 --- a/http2irc.py +++ b/http2irc.py @@ -172,12 +172,12 @@ class MessageQueue: def put_nowait(self, item): self._queue.append(item) - if self._getter is not None: + if self._getter is not None 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: + if self._getter is not None and not self._getter.cancelled(): self._getter.set_result(None) def qsize(self): -- cgit v1.3.1-10-gc9f91