Using sys.stdin with asyncio readers. Doesn't work on Windows because sys.stdin isn't a socket

async_stdin.py

import sys
import asyncio
from collections import deque


_loop = asyncio.get_event_loop()
_queue = deque()


def __reader(self):
    data = sys.stdin.readline()
    self._queue.popleft().set_result(data)

async def get_input(loop=None):
    loop = loop or _loop
    try:
        future = loop.create_future()
        _queue.append(future)

        if not (len(_queue) - 1):
            loop.call_soon(loop.add_reader, sys.stdin, __reader)
        return await future
    finally:
        if not _queue:
            loop.call_soon(loop.remove_reader, sys.stdin)