(handles, interval, output_path)
| 170 | await write_func(line) |
| 171 | |
| 172 | async def run_fully_async(handles, interval, output_path): |
| 173 | async with ( |
| 174 | WriteThread(output_path) as output, |
| 175 | asyncio.TaskGroup() as group, |
| 176 | ): |
| 177 | for handle in handles: |
| 178 | group.create_task( |
| 179 | tail_async(handle, interval, output.write) |
| 180 | ) |
| 181 | |
| 182 | |
| 183 | print("Example 9") |
no test coverage detected