aboutsummaryrefslogtreecommitdiff
path: root/http2irc.py
diff options
context:
space:
mode:
Diffstat (limited to 'http2irc.py')
-rw-r--r--http2irc.py4
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):