asvetlov

import asyncio


@asyncio.coroutine
def sender(queue):
    print('sender started')
    try:
        yield from asyncio.sleep(3)
        while True:
            data = yield from queue.get()