@asyncio.coroutine
def getter():
    (yield)
    num = queue.qsize()
    for _ in range(num):
        queue.get_nowait()
@asyncio.coroutine
def getter():
    (yield)
    num = queue.qsize()
    for _ in range(num):
        queue.get_nowait()