python async console inputs

unix.py

import asyncio
import os
import sys
from typing import AsyncGenerator
from contextlib import closing

async def console_input() -> AsyncGenerator[str, None]:
    loop = asyncio.get_event_loop()
    reader = asyncio.StreamReader(loop=loop)
    with os.fdopen(os.dup(sys.stdin.fileno()), mode='rt+') as file_ref:
        
        transport, reader_protocol = await loop.connect_read_pipe(
            protocol_factory=lambda : asyncio.StreamReaderProtocol(stream_reader=reader, loop=loop),
            pipe=file_ref
        )
        with closing(transport):
            async for buffer in reader:
                yield buffer.decode()

windows.py

import asyncio
import asyncio.windows_utils
import msvcrt
import os
import sys
from ctypes import WinError, windll
from typing import AsyncGenerator

kernel32 = windll.kernel32

async def console_input() -> AsyncGenerator[str, None]:
    loop = asyncio.get_event_loop()
    running = False
    with os.fdopen(fd=os.dup(sys.stdin.fileno()), mode='rt+') as reader:
        try:
            while reader.readable():
                running = True
                next_line = await loop.run_in_executor(None, reader.readline, -1)
                running = False
                if next_line is None or next_line == '':
                    return
                yield next_line.rstrip()
        finally:
            result = -1
            if running:
                result = kernel32.CancelIoEx(msvcrt.get_osfhandle(reader.fileno()), None)
            if result == 0:
                raise WinError()