Communicate blocks the asyncio loop briefly at the start

[lanzz]

Communicate blocks the asyncio loop briefly at the start

[rany2]

I modified your script slightly and can't repro. I don't notice any blocks either. This is what I used to confirm this:

import asyncio
import edge_tts
import timeit


TEXT = (
    'Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt '
    'ut labore et dolore magna aliqua. Ut enim ad minim veniam, quis nostrud exercitation ullamco '
    'laboris nisi ut aliquip ex ea commodo consequat. Duis aute irure dolor in reprehenderit in '
    'voluptate velit esse cillum dolore eu fugiat nulla pariatur. Excepteur sint occaecat '
    'cupidatat non proident, sunt in culpa qui officia deserunt mollit anim id est laborum.'
)

async def edge_request():
    req = edge_tts.Communicate(TEXT)
    return b''.join([chunk['data'] async for chunk in req.stream() if chunk['type'] == 'audio'])


async def dummy_sleep():
    await asyncio.sleep(2)


async def test(fn) -> None:
    print(f'testing {fn!r}')
    x = 0
    y = timeit.default_timer()
    i = 0
    edge_task = asyncio.create_task(fn())
    while not edge_task.done():
        await asyncio.wait({edge_task}, timeout=.1)
        x = y
        y = timeit.default_timer()
        i += 1
        print(f'elapsed time: {y - x:.2f} seconds ({i} iterations)')



asyncio.run(test(edge_request))
asyncio.run(test(dummy_sleep))

[rany2]

I know that async on Windows is pretty buggy, so maybe you're using that platform?

[lanzz]

Yeah, I can confirm that this only occurs on Windows, tested on macOS and Linux and there's no block there. Oh well.