Jakiego obiektu deskryptora pliku Python asyncio's Loop.add_reader () oczekuje się?

Próbuję zrozumieć, jak korzystać z nowej funkcjonalności asyncio w Pythonie 3.4 i zmagam się z tym, jak korzystać z event_loop.add_reader () <). Z Ograniczone dyskusje, które znalazłem, wygląda na to, że czytanie standardowego Oddzielny proces w przeciwieństwie do zawartości otwartego pliku. Czy to prawda? Jeśli tak, wydaje się, że nie ma asyncio specyficzny sposób, aby zintegrować standardowy plik IO, czy to prawda?

Gram z poniższym kodem. Wyjście poniższych daje wyjątek PermissionError: [Errno 1] Operation not permitted z linii 399 z /Python3.4/selektors.py self._epoll.register(key.fd, epoll_events) jest wywołany przez linię add_reader() poniżej

import asyncio
import urllib.parse
import sys
import pdb
import os

def fileCallback(*args):
    pdb.set_trace()

path = sys.argv[1]
loop = asyncio.get_event_loop()
#fd = os.open(path, os.O_RDONLY)
fd = open(path, 'r')
#data = fd.read()
#print(data)
#fd.close()
pdb.set_trace()
task = loop.add_reader(fd, fileCallback, fd)
loop.run_until_complete(task)
loop.close()

EDYTUJ

Dla tych, którzy szukają przykładu sposobu korzystania z asyncio do czytania więcej niż jednego pliku na raz, jakbym był ciekawy, oto przykład tego, jak można go osiągnąć. Sekret jest w linii yield from asyncio.sleep(0). Zasadniczo zatrzymuje się bieżącą funkcję, umieszczając ją z powrotem w kolejce pętli zdarzeń, do wywołania po wykonaniu wszystkich innych gotowych funkcji. Funkcje są zdecydowane być gotowe na podstawie tego, jak zostały zaplanowane.

import asyncio

@asyncio.coroutine
def read_section(file, length):
    yield from asyncio.sleep(0)
    return file.read(length)

@asyncio.coroutine
def read_file(path):
    fd = open(path, 'r')
    retVal = []
    cnt = 0
    while True:
        cnt = cnt + 1
        data = yield from read_section(fd, 102400)
        print(path + ': ' + str(cnt) + ' - ' + str(len(data)))
        if len(data) == 0:
            break;
    fd.close()

paths = ["loadme.txt", "loadme also.txt"]
loop = asyncio.get_event_loop()
tasks = []
for path in paths:
    tasks.append(asyncio.async(read_file(path)))
loop.run_until_complete(asyncio.wait(tasks))
loop.close()