|
|
@@ -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): |
|
|
|