aiokq/misc/kqdir.py

import aiokq
import asyncio
import os

fd = os.open('.', os.O_RDONLY)

async def foo():
	async with aiokq.watch_file(fd) as wf:
		print('a')
		await wf()
		print('b')

loop = asyncio.get_event_loop()
loop.run_until_complete(foo())