diff options
| -rw-r--r-- | http2irc.py | 4 |
1 files 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): |