import asyncio
import subprocess
import sys

import winloop


async def main() -> None:
    process = await asyncio.create_subprocess_exec(
        sys.executable, "-c", "", stdin=subprocess.PIPE
    )
    assert process.stdin is not None
    # Wait for the other end of the pipe to be closed:
    await process.wait()
    # Confirm that the IO manager knows that the pipe was closed:
    assert process.stdin.is_closing()
    # Therefore one of these should raise:
    process.stdin.write(b"foo")  # raises on uvloop
    await process.stdin.drain()  # raises on stdlib
    # But neither raises on Winloop currently! However, on Winloop they will raise if
    # called subsequently:
    # await process.stdin.drain()


# asyncio.run(main())
asyncio.run(main(), loop_factory=winloop.new_event_loop)