Function tail_async

example_code/item_077.py:237–246

(handle, interval, write_func)

print("Example 8")
async def tail_async(handle, interval, write_func):
    loop = asyncio.get_event_loop()

    while not handle.closed:
        try:
            line = await loop.run_in_executor(None, readline, handle)
        except NoNewData:
            await asyncio.sleep(interval)
        else:
            await write_func(line)


print("Example 9")