Get and send data asyncio queue.

get_send.py

import asyncio
from queue import Queue

q = asyncio.Queue()


async def get_data():
    while True:
        await asyncio.sleep(0.5)  # simulate work
        print("receiving:", await q.get())


async def send_data():
    for i in range(10):
        await asyncio.sleep(0.3)  # simulate work
        print("sending:", i)
        await q.put(i)


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.create_task(get_data())
    loop.run_until_complete(send_data())