removed queue and replaced with asyncio.Queue