def put(self, item):
"""Put an item into the queue.
- If you yield from put(), wait until a free slot is available
- before adding item.
+ Put an item into the queue. If the queue is full, wait until a free
+ slot is available before adding item.
+
+ This method is a coroutine.
"""
self._consume_done_getters()
if self._getters:
def get(self):
"""Remove and return an item from the queue.
- If you yield from get(), wait until a item is available.
+ If queue is empty, wait until an item is available.
+
+ This method is a coroutine.
"""
self._consume_done_putters()
if self._putters: