18.5.1. Базовый цикл событий¶Base Event Loop

18.5.1.1. Запуск цикла событий¶Run an event loop

AbstractEventLoop.run_forever()¶

Выполняется до вызова stop(). Если stop() вызывается до вызова run_forever(), то однократно опрашивается I/O-селектор с нулевым тайм-аутом, выполняются все колбэки, запланированные в ответ на I/O-события (а также уже запланированные), после чего происходит выход. Если stop() вызывается во время выполнения run_forever(), то будет выполнен текущий набор колбэков, после чего произойдёт выход. Обратите внимание, что колбэки, запланированные другими колбэками, в этом случае не выполнятся; они выполнятся при следующем вызове run_forever().

Изменено в версии 3.5.1.

AbstractEventLoop.run_until_complete(future)¶

Выполняется до завершения Future.

Если аргумент является объектом корутины, он оборачивается с помощью ensure_future().

Возвращает результат Future или возбуждает его исключение.

AbstractEventLoop.is_running()¶

Возвращает статус выполнения цикла событий.

AbstractEventLoop.stop()¶

Останавливает выполнение цикла событий.

Это приводит к выходу из run_forever() при следующей удобной возможности (см. там подробнее).

Изменено в версии 3.5.1.

AbstractEventLoop.is_closed()¶

Возвращает True, если цикл событий был закрыт.

Новое в версии 3.4.2.

AbstractEventLoop.close()¶

Закрывает цикл событий. Цикл не должен выполняться. Ожидающие колбэки будут потеряны.

Это очищает очереди и завершает работу исполнителя, но не дожидается его полной остановки.

Это идемпотентно и необратимо. После этого метода не следует вызывать никакие другие методы.

18.5.1.2. Вызовы¶Calls

Большинство функций asyncio не принимают именованные аргументы. Если вы хотите передать именованные аргументы в свой колбэк, используйте functools.partial(). Например, loop.call_soon(functools.partial(print, "Hello", flush=True)) вызовет print("Hello", flush=True).

AbstractEventLoop.call_soon(callback, *args)¶

Планирует вызов колбэка как можно скорее. Колбэк вызывается после возврата call_soon(), когда управление возвращается в цикл событий.

Это работает как очередь FIFO: колбэки вызываются в порядке, в котором они зарегистрированы. Каждый колбэк вызывается ровно один раз.

Любые позиционные аргументы, указанные после колбэка, будут переданы ему при вызове.

Возвращается экземпляр asyncio.Handle, который можно использовать для отмены колбэка.

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.call_soon_threadsafe(callback, *args)¶

Аналогично call_soon(), но потокобезопасно.

См. раздел concurrency and multithreading документации.

18.5.1.3. Отложенные вызовы¶Delayed calls

Цикл событий имеет собственные внутренние часы для вычисления тайм-аутов. Какие именно часы используются, зависит от реализации цикла событий (зависящей от платформы); в идеале это монотонные часы. Обычно это другие часы, нежели time.time().

AbstractEventLoop.call_later(delay, callback, *args)¶

Организует вызов колбэка через заданную задержку в секундах (целое число или float).

Возвращается экземпляр asyncio.Handle, который можно использовать для отмены колбэка.

Колбэк будет вызван ровно один раз на каждый вызов call_later(). Если два колбэка запланированы на одно и то же время, порядок их вызова не определён.

Необязательные позиционные args будут переданы колбэку при его вызове. Если нужно передать колбэку именованные аргументы, используйте замыкание или functools.partial().

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.call_at(when, callback, *args)¶

Организует вызов колбэка в указанную абсолютную метку времени when (целое число или float), используя ту же систему отсчёта времени, что и AbstractEventLoop.time().

Поведение этого метода аналогично call_later().

Возвращается экземпляр asyncio.Handle, который можно использовать для отмены колбэка.

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.time()¶

Возвращает текущее время в виде значения float в соответствии с внутренними часами цикла событий.

18.5.1.4. Futures¶

AbstractEventLoop.create_future()¶

Создаёт объект asyncio.Future, привязанный к циклу событий.

Это предпочтительный способ создания Future-объектов в asyncio, поскольку реализации цикла событий могут предоставлять альтернативные реализации класса Future (с улучшенной производительностью или инструментарием).

Новое в версии 3.5.2.

18.5.1.5. Задачи¶Tasks

AbstractEventLoop.create_task(coro)¶

Планирует выполнение корутинного объекта: оборачивает его в future. Возвращает объект Task.

Сторонние циклы событий могут использовать собственный подкласс Task для взаимодействия. В этом случае тип результата – подкласс Task.

Этот метод был добавлен в Python 3.4.2. Используйте функцию async() для поддержки более старых версий Python.

Новое в версии 3.4.2.

AbstractEventLoop.set_task_factory(factory)¶

Устанавливает фабрику задач, которая будет использоваться AbstractEventLoop.create_task().

Если factory равно None, будет установлена фабрика задач по умолчанию.

Если factory является вызываемым объектом, его сигнатура должна соответствовать (loop, coro), где loop – ссылка на активный цикл событий, coro – объект корутины. Вызываемый объект должен возвращать объект, совместимый с asyncio.Future.

Новое в версии 3.4.4.

AbstractEventLoop.get_task_factory()¶

Возвращает фабрику задач или None, если используется стандартная.

Новое в версии 3.4.4.

18.5.1.6. Создание соединений¶Creating connections

coroutine AbstractEventLoop.create_connection(protocol_factory, host=None, port=None, *, ssl=None, family=0, proto=0, flags=0, sock=None, local_addr=None, server_hostname=None)¶

Создаёт потоковое транспортное соединение с указанными интернет-хостом host и портом port: семейство сокетов AF_INET или AF_INET6 в зависимости от host (или family, если указано), тип сокета SOCK_STREAM. protocol_factory должен быть вызываемым объектом, возвращающим экземпляр протокола.

Этот метод является корутиной, которая пытается установить соединение в фоновом режиме. В случае успеха корутина возвращает пару (transport, protocol).

Хронологическая последовательность выполняемой операции следующая:

1. Соединение установлено, и создаётся транспорт, представляющий его.
2. protocol_factory вызывается без аргументов и должен возвращать экземпляр протокола.
3. Экземпляр протокола привязывается к транспорту, и вызывается его метод connection_made().
4. Корутина успешно возвращает пару (transport, protocol).

Созданный транспорт является двунаправленным потоком, зависящим от реализации.

Примечание

protocol_factory может быть любым вызываемым объектом, не обязательно классом. Например, если нужно использовать уже созданный экземпляр протокола, можно передать lambda: my_protocol.

Параметры, изменяющие способ создания соединения:

• ssl: если указан и не равен false, создаётся SSL/TLS транспорт (по умолчанию создаётся обычный TCP транспорт). Если ssl является объектом ssl.SSLContext, этот контекст используется для создания транспорта; если ssl равен True, используется контекст с некоторыми неопределёнными настройками по умолчанию.

  См. также

  Вопросы безопасности SSL/TLS

• server_hostname используется только вместе с ssl и задаёт или переопределяет имя хоста, с которым будет сравниваться сертификат целевого сервера. По умолчанию используется значение аргумента host. Если host пуст, значение по умолчанию отсутствует, и необходимо передать значение для server_hostname. Если server_hostname является пустой строкой, проверка имени хоста отключается (что представляет серьёзную угрозу безопасности, допуская атаки man-in-the-middle).

• family, proto, flags – необязательные семейство адресов, протокол и флаги, которые передаются в getaddrinfo() для разрешения host. Если заданы, все они должны быть целыми числами из соответствующих констант модуля socket.

• Если задан sock, он должен быть существующим, уже подключённым объектом socket.socket, который будет использоваться транспортом. Если sock задан, ни один из параметров host, port, family, proto, flags и local_addr не должен быть указан.

• local_addr, если указан, представляет собой кортеж (local_host, local_port), используемый для локальной привязки сокета. local_host и local_port ищутся с помощью getaddrinfo(), аналогично host и port.

Изменено в версии 3.5: На Windows с ProactorEventLoop теперь поддерживается SSL/TLS.

См. также

Функция open_connection() может использоваться для получения пары (StreamReader, StreamWriter) вместо протокола.

coroutine AbstractEventLoop.create_datagram_endpoint(protocol_factory, local_addr=None, remote_addr=None, *, family=0, proto=0, flags=0, reuse_address=None, reuse_port=None, allow_broadcast=None, sock=None)¶

Создание датаграммного соединения: семейство сокетов AF_INET или AF_INET6 в зависимости от host (или family, если указано), тип сокета SOCK_DGRAM. protocol_factory должен быть вызываемым объектом, возвращающим экземпляр протокола.

Этот метод является корутиной, которая пытается установить соединение в фоновом режиме. В случае успеха корутина возвращает пару (transport, protocol).

Параметры, изменяющие способ создания соединения:

• local_addr, если задан, представляет собой кортеж (local_host, local_port), используемый для привязки сокета локально. local_host и local_port разрешаются с помощью getaddrinfo().
• remote_addr, если задан, представляет собой кортеж (remote_host, remote_port), используемый для подключения сокета к удалённому адресу. remote_host и remote_port разрешаются с помощью getaddrinfo().
• family, proto, flags – необязательные семейство адресов, протокол и флаги, передаваемые в getaddrinfo() для разрешения host. Если заданы, все они должны быть целыми числами из соответствующих констант модуля socket.
• reuse_address указывает ядру повторно использовать локальный сокет в состоянии TIME_WAIT, не дожидаясь истечения его естественного таймаута. Если не указано, автоматически устанавливается в True на UNIX.
• reuse_port сообщает ядру, что данная конечная точка может быть привязана к тому же порту, что и другие существующие конечные точки, при условии, что все они устанавливают этот флаг при создании. Этот параметр не поддерживается в Windows и некоторых UNIX. Если константа SO_REUSEPORT не определена, эта возможность не поддерживается.
• allow_broadcast указывает ядру разрешить этой конечной точке отправлять сообщения на широковещательный адрес.
• sock может быть указан необязательно, чтобы использовать уже существующий, подключённый объект socket.socket для транспорта. Если указан, local_addr и remote_addr должны быть опущены (должны быть None).

В Windows с ProactorEventLoop этот метод не поддерживается.

См. примеры протокол UDP-клиента эхо и протокол UDP-сервера эхо.

coroutine AbstractEventLoop.create_unix_connection(protocol_factory, path, *, ssl=None, sock=None, server_hostname=None)¶

Создание UNIX-соединения: семейство сокетов AF_UNIX, тип сокета SOCK_STREAM. Семейство сокетов AF_UNIX используется для эффективного взаимодействия между процессами на одной машине.

Этот метод является корутиной, которая пытается установить соединение в фоновом режиме. В случае успеха корутина возвращает пару (transport, protocol).

path – это имя сокета домена UNIX и требуется, если не указан параметр sock. Поддерживаются абстрактные UNIX-сокеты, пути str и bytes.

О параметрах см. метод AbstractEventLoop.create_connection().

Доступность: UNIX.

18.5.1.7. Создание прослушивающих соединений¶Creating listening connections

coroutine AbstractEventLoop.create_server(protocol_factory, host=None, port=None, *, family=socket.AF_UNSPEC, flags=socket.AI_PASSIVE, sock=None, backlog=100, ssl=None, reuse_address=None, reuse_port=None)¶

Создаёт TCP-сервер (тип сокета SOCK_STREAM), привязанный к host и port.

Возвращает объект Server, его атрибут sockets содержит созданные сокеты. Используйте метод Server.close() для остановки сервера: закрыть слушающие сокеты.

Параметры:

• Параметр host может быть строкой; в этом случае TCP-сервер привязывается к host и port. Параметр host также может быть последовательностью строк, и тогда TCP-сервер привязывается ко всем хостам из этой последовательности. Если host – пустая строка или None, подразумеваются все интерфейсы, и будет возвращён список из нескольких сокетов (скорее всего, один для IPv4 и один для IPv6).
• family можно установить в socket.AF_INET или AF_INET6, чтобы заставить сокет использовать IPv4 или IPv6. Если не установлено, значение будет определено из host (по умолчанию socket.AF_UNSPEC).
• flags – битовая маска для getaddrinfo().
• sock можно указать, чтобы использовать уже существующий объект сокета. Если он указан, host и port следует опустить (они должны быть None).
• backlog – максимальное количество соединений в очереди, передаваемое в listen() (по умолчанию 100).
• ssl можно установить в SSLContext, чтобы включить SSL для принятых соединений.
• reuse_address указывает ядру повторно использовать локальный сокет в состоянии TIME_WAIT, не дожидаясь истечения его естественного таймаута. Если не указано, автоматически устанавливается в True на UNIX.
• reuse_port указывает ядру разрешить привязку этой конечной точки к тому же порту, к которому привязаны другие существующие конечные точки, при условии, что все они устанавливают этот флаг при создании. Эта опция не поддерживается в Windows.

Этот метод является корутиной.

Изменено в версии 3.5: На Windows с ProactorEventLoop теперь поддерживается SSL/TLS.

См. также

Функция start_server() создаёт пару (StreamReader, StreamWriter) и вызывает колбэк с этой парой.

Изменено в версии 3.5.1: Параметр host теперь может быть последовательностью строк.

coroutine AbstractEventLoop.create_unix_server(protocol_factory, path=None, *, sock=None, backlog=100, ssl=None)¶

Аналогично AbstractEventLoop.create_server(), но для семейства сокетов AF_UNIX.

Этот метод является корутиной.

Доступность: UNIX.

coroutine BaseEventLoop.connect_accepted_socket(protocol_factory, sock, *, ssl=None)¶

Обработать принятое соединение.

Это используется серверами, которые принимают соединения вне asyncio, но используют asyncio для их обработки.

Параметры:

• sock – это уже существующий объект сокета, возвращённый вызовом accept.
• ssl можно установить в SSLContext, чтобы включить SSL для принятых соединений.

Этот метод является корутиной. После завершения корутина возвращает пару (transport, protocol).

18.5.1.8. Отслеживание файловых дескрипторов¶Watch file descriptors

На Windows с SelectorEventLoop поддерживаются только дескрипторы сокетов (например, файловые дескрипторы каналов не поддерживаются).

На Windows с ProactorEventLoop эти методы не поддерживаются.

AbstractEventLoop.add_reader(fd, callback, *args)¶

Начать наблюдение за файловым дескриптором на готовность к чтению и затем вызвать колбэк с указанными аргументами.

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.remove_reader(fd)¶

Прекратить наблюдение за файловым дескриптором на готовность к чтению.

AbstractEventLoop.add_writer(fd, callback, *args)¶

Начать наблюдение за файловым дескриптором на готовность к записи и затем вызвать колбэк с указанными аргументами.

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.remove_writer(fd)¶

Прекратить наблюдение за файловым дескриптором на готовность к записи.

Пример наблюдения за файловым дескриптором на события чтения использует низкоуровневый метод AbstractEventLoop.add_reader() для регистрации файлового дескриптора сокета.

18.5.1.9. Низкоуровневые операции с сокетами¶Low-level socket operations

coroutine AbstractEventLoop.sock_recv(sock, nbytes)¶

Получает данные из сокета. Аналогично блокирующему методу socket.socket.recv().

Возвращаемое значение – объект bytes, представляющий полученные данные. Максимальный объём данных, который можно получить за один раз, задаётся параметром nbytes.

В SelectorEventLoop цикле событий сокет sock должен быть неблокирующим.

Этот метод является корутиной.

coroutine AbstractEventLoop.sock_sendall(sock, data)¶

Отправляет данные в сокет. Аналогично блокирующему методу socket.socket.sendall().

Сокет должен быть подключён к удалённому сокету. Этот метод продолжает отправлять данные из data, пока либо не будут отправлены все данные, либо не произойдёт ошибка. В случае успеха возвращается None. При ошибке возникает исключение, и невозможно определить, сколько данных (если вообще какие-то) было успешно обработано принимающей стороной соединения.

В SelectorEventLoop цикле событий сокет sock должен быть неблокирующим.

Этот метод является корутиной.

coroutine AbstractEventLoop.sock_connect(sock, address)¶

Подключается к удалённому сокету по адресу address. Аналогично блокирующему методу socket.socket.connect().

В SelectorEventLoop цикле событий сокет sock должен быть неблокирующим.

Этот метод является корутиной.

Изменено в версии 3.5.2: address больше не требует разрешения. sock_connect попытается проверить, разрешён ли уже address, вызвав socket.inet_pton(). Если нет, AbstractEventLoop.getaddrinfo() будет использован для разрешения address.

См. также

AbstractEventLoop.create_connection() и asyncio.open_connection().

coroutine AbstractEventLoop.sock_accept(sock)¶

Принимает соединение. Аналогично блокирующему socket.socket.accept().

Сокет должен быть привязан к адресу и ожидать подключения. Возвращаемое значение – пара (conn, address), где conn – это новый объект сокета, пригодный для отправки и получения данных по соединению, а address – адрес, привязанный к сокету на другом конце соединения.

Сокет sock должен быть неблокирующим.

Этот метод является корутиной.

См. также

AbstractEventLoop.create_server() и start_server().

18.5.1.10. Разрешение имени хоста¶Resolve host name

coroutine AbstractEventLoop.getaddrinfo(host, port, *, family=0, type=0, proto=0, flags=0)¶

Этот метод – корутина, аналогичная функции socket.getaddrinfo(), но неблокирующая.

coroutine AbstractEventLoop.getnameinfo(sockaddr, flags=0)¶

Этот метод – корутина, аналогичная функции socket.getnameinfo(), но неблокирующая.

18.5.1.11. Подключение каналов¶Connect pipes

В Windows с SelectorEventLoop эти методы не поддерживаются. Используйте ProactorEventLoop для поддержки каналов в Windows.

coroutine AbstractEventLoop.connect_read_pipe(protocol_factory, pipe)¶

Регистрирует канал чтения в цикле событий.

protocol_factory должен создавать объект с интерфейсом Protocol. pipe – это объект, подобный файлу. Возвращает пару (transport, protocol), где транспорт поддерживает интерфейс ReadTransport.

При SelectorEventLoop цикле событий канал pipe переводится в неблокирующий режим.

Этот метод является корутиной.

coroutine AbstractEventLoop.connect_write_pipe(protocol_factory, pipe)¶

Регистрирует канал записи в цикле событий.

protocol_factory должен создавать объект с интерфейсом BaseProtocol. pipe – это объект, подобный файлу. Возвращает пару (transport, protocol), где транспорт поддерживает интерфейс WriteTransport.

При SelectorEventLoop цикле событий канал pipe переводится в неблокирующий режим.

Этот метод является корутиной.

18.5.1.12. Сигналы UNIX¶UNIX signals

Доступно: только UNIX.

AbstractEventLoop.add_signal_handler(signum, callback, *args)¶

Добавляет обработчик сигнала.

Вызывает ValueError, если номер сигнала недопустим или его невозможно перехватить. Вызывает RuntimeError, если возникла проблема при установке обработчика.

Используйте functools.partial для передачи именованных аргументов в колбэк.

AbstractEventLoop.remove_signal_handler(sig)¶

Удаляет обработчик сигнала.

Возвращает True, если обработчик сигнала был удалён, и False в противном случае.

18.5.1.13. Исполнитель¶Executor

Вызывает функцию в Executor (пуле потоков или пуле процессов). По умолчанию цикл событий использует исполнитель с пулом потоков (ThreadPoolExecutor).

coroutine AbstractEventLoop.run_in_executor(executor, func, *args)¶

Планирует вызов функции func в указанном исполнителе.

Аргумент исполнитель должен быть экземпляром Executor Исполнитель по умолчанию используется, если исполнитель равен None.

Используйте functools.partial для передачи именованных аргументов в *func*.

Этот метод является корутиной.

Изменено в версии 3.5.3: BaseEventLoop.run_in_executor() больше не настраивает max_workers создаваемого исполнителя пула потоков, оставляя настройку по умолчанию самому исполнителю пула потоков (ThreadPoolExecutor).

AbstractEventLoop.set_default_executor(executor)¶

Устанавливает исполнитель по умолчанию, используемый run_in_executor().

18.5.1.14. API обработки ошибок¶Error Handling API

Позволяет настраивать обработку исключений в цикле событий.

AbstractEventLoop.set_exception_handler(handler)¶

Устанавливает handler в качестве нового обработчика исключений цикла событий.

Если handler равен None, будет установлен обработчик исключений по умолчанию.

Если handler – вызываемый объект, его сигнатура должна совпадать с (loop, context), где loop будет ссылкой на активный цикл событий, context будет объектом dict (см. документацию call_exception_handler() для подробностей о контексте).

AbstractEventLoop.get_exception_handler()¶

Возвращает обработчик исключений или None, если используется стандартный.

Новое в версии 3.5.2.

AbstractEventLoop.default_exception_handler(context)¶

Обработчик исключений по умолчанию.

Вызывается при возникновении исключения, когда не установлен обработчик исключений, а также может вызываться пользовательским обработчиком исключений, который хочет передать управление стандартному поведению.

Параметр context имеет то же значение, что и в call_exception_handler().

AbstractEventLoop.call_exception_handler(context)¶

Вызывает обработчик исключений текущего цикла событий.

context – объект dict, содержащий следующие ключи (новые ключи могут быть добавлены позже):

• ‘message’: сообщение об ошибке;
• 'исключение' (необязательно): объект исключения;
• ‘future’ (необязательно): экземпляр asyncio.Future;
• ‘handle’ (необязательно): экземпляр asyncio.Handle;
• 'протокол' (необязательно): экземпляр Protocol;
• 'транспорт' (необязательно): экземпляр Transport;
• ‘socket’ (необязательно): экземпляр socket.socket.

Примечание

Примечание: этот метод не следует переопределять в подклассах циклов событий. Для любой пользовательской обработки исключений используйте метод set_exception_handler().

18.5.1.15. Режим отладки¶Debug mode

AbstractEventLoop.get_debug()¶

Возвращает режим отладки (bool) цикла событий.

Значение по умолчанию – True, если переменная окружения PYTHONASYNCIODEBUG имеет непустое строковое значение, и False в противном случае.

Новое в версии 3.4.2.

AbstractEventLoop.set_debug(enabled: bool)¶

Устанавливает режим отладки цикла событий.

Новое в версии 3.4.2.

18.5.1.16. Сервер¶Server

class asyncio.Server¶

Сервер, прослушивающий сокеты.

Объект, создаваемый методом AbstractEventLoop.create_server() и функцией start_server(). Не создавайте экземпляр класса напрямую.

close()¶

Прекращает обслуживание: закрывает слушающие сокеты и устанавливает атрибут sockets в None.

Сокеты существующих входящих подключений клиентов остаются открытыми.

Сервер закрывается асинхронно, используйте wait_closed()\nкорутину, чтобы дождаться закрытия сервера.

coroutine wait_closed()¶

Ожидайте завершения метода close().

Этот метод является корутиной.

sockets¶

Список объектов socket.socket, которые прослушивает сервер, или None, если сервер закрыт.

18.5.1.17. Handle¶

class asyncio.Handle¶

Объект-обёртка колбэка, возвращаемый функциями AbstractEventLoop.call_soon(), AbstractEventLoop.call_soon_threadsafe(), AbstractEventLoop.call_later() и AbstractEventLoop.call_at().

cancel()¶

Отменяет вызов. Если колбэк уже отменён или выполнен, этот метод ничего не делает.

18.5.1.18. Примеры циклов событий¶Event loop examples

import asyncio

def hello_world(loop):
    print('Hello World')
    loop.stop()

loop = asyncio.get_event_loop()

# Запланировать вызов hello_world()
loop.call_soon(hello_world, loop)

# Блокирующий вызов прерван loop.stop()
loop.run_forever()
loop.close()

import asyncio
import datetime

def display_date(end_time, loop):
    print(datetime.datetime.now())
    if (loop.time() + 1.0) < end_time:
        loop.call_later(1, display_date, end_time, loop)
    else:
        loop.stop()

loop = asyncio.get_event_loop()

# Запланировать первый вызов display_date()
end_time = loop.time() + 5.0
loop.call_soon(display_date, end_time, loop)

# Блокирующий вызов прерван loop.stop()
loop.run_forever()
loop.close()

import asyncio
try:
    from socket import socketpair
except ImportError:
    from asyncio.windows_utils import socketpair

# Создать пару связанных файловых дескрипторов
rsock, wsock = socketpair()
loop = asyncio.get_event_loop()

def reader():
    data = rsock.recv(100)
    print("Received:", data.decode())
    # Готово: отменить регистрацию файлового дескриптора
    loop.remove_reader(rsock)
    # Остановить цикл событий
    loop.stop()

# Зарегистрировать файловый дескриптор для события чтения
loop.add_reader(rsock, reader)

# Симулировать приём данных из сети
loop.call_soon(wsock.send, 'abc'.encode())

# Запустить цикл событий
loop.run_forever()

# Готово, закрыть сокеты и цикл событий.
rsock.close()
wsock.close()
loop.close()

import asyncio
import functools
import os
import signal

def ask_exit(signame):
    print("got signal %s: exit" % signame)
    loop.stop()

loop = asyncio.get_event_loop()
for signame in ('SIGINT', 'SIGTERM'):
    loop.add_signal_handler(getattr(signal, signame),
                            functools.partial(ask_exit, signame))

print("Event loop running forever, press Ctrl+C to interrupt.")
print("pid %s: send SIGINT or SIGTERM to exit." % os.getpid())
try:
    loop.run_forever()
finally:
    loop.close()