Esta documentação é de uma versão antiga do Python que não é mais atualizada. Você deveria atualizar e ler a documentação do Python para versão estável atual.

# Índice de APIs de baixo nível

Esta página lista todas as APIs de baixo nível do asyncio.

## Obtendo o Loop de Eventos

`asyncio.get_running_loop()` | A função preferida para obter o laço de eventos em execução.
`asyncio.get_event_loop()` | Obtém uma instância de laço de eventos (atual ou através da política).
`asyncio.set_event_loop()` | Define o laço de eventos como atual através da política atual.
`asyncio.new_event_loop()` | Cria um novo laço de eventos.

Exemplos

- Usando asyncio.get_running_loop().

## Métodos do laço de eventos

Veja também a seção principal da documentação sobre os métodos de laço de eventos.

Ciclo de vida

`loop.run_until_complete()` | Executa um Future/Task/aguardável até que esteja completo.
`loop.run_forever()` | Executa o laço de eventos para sempre.
`loop.stop()` | Para o laço de eventos.
`loop.close()` | Fecha o loop de eventos.
`loop.is_running()` | Retorna `True` se o laço de eventos estiver rodando.
`loop.is_closed()` | Retorna `True` se o laço de eventos estiver fechado.
`await` `loop.shutdown_asyncgens()` | Fecha geradores assíncronos.

Depuração

`loop.set_debug()` | Habilita ou desabilita o modo de debug.
`loop.get_debug()` | Obtém o modo de debug atual.

Agendando funções de retorno (callbacks)

`loop.call_soon()` | Invoca uma função de retorno brevemente.
`loop.call_soon_threadsafe()` | Uma variante segura para thread de `loop.call_soon()`.
`loop.call_later()` | Invoca uma função de retorno após o tempo especificado.
`loop.call_at()` | Invoca uma função de retorno no instante especificado.

Grupo de Thread/Processo

`await` `loop.run_in_executor()` | Executa uma função vinculada à CPU ou outra que seja bloqueante em um executor `concurrent.futures`.
`loop.set_default_executor()` | Define o executor padrão para `loop.run_in_executor()`.

Tasks e Futures

`loop.create_future()` | Cria um objeto `Future`.
`loop.create_task()` | Agenda corrotina como uma `Task`.
`loop.set_task_factory()` | Define uma factory usada por `loop.create_task()` para criar `Tasks`.
`loop.get_task_factory()` | Obtém o factory `loop.create_task()` usado para criar `Tasks`.

DNS

`await` `loop.getaddrinfo()` | Versão assíncrona de `socket.getaddrinfo()`.
`await` `loop.getnameinfo()` | Versão assíncrona de `socket.getnameinfo()`.

Rede e IPC

`await` `loop.create_connection()` | Abre uma conexão TCP.
`await` `loop.create_server()` | Cria um servidor TCP.
`await` `loop.create_unix_connection()` | Abre uma conexão soquete Unix.
`await` `loop.create_unix_server()` | Cria um servidor soquete Unix.
`await` `loop.connect_accepted_socket()` | Envolve um `socket` em um par `(transport, protocol)`.
`await` `loop.create_datagram_endpoint()` | Abre uma conexão por datagrama (UDP).
`await` `loop.sendfile()` | Envia um arquivo por meio de um transporte.
`await` `loop.start_tls()` | Atualiza uma conexão existente para TLS.
`await` `loop.connect_read_pipe()` | Envolve a leitura final de um encadeamento em um par `(transport, protocol)`.
`await` `loop.connect_write_pipe()` | Envolve a escrita final de um encadeamento em um par `(transport, protocol)`.

Sockets

`await` `loop.sock_recv()` | Recebe dados do `socket`.
`await` `loop.sock_recv_into()` | Recebe dados do `socket` em um buffer.
`await` `loop.sock_sendall()` | Envia dados para o `socket`.
`await` `loop.sock_connect()` | Conecta ao `socket`.
`await` `loop.sock_accept()` | Aceita uma conexão do `socket`.
`await` `loop.sock_sendfile()` | Envia um arquivo usando o `socket`.
`loop.add_reader()` | Começa a observar um descritor de arquivo, aguardando por disponibilidade de leitura.
`loop.remove_reader()` | Interrompe o monitoramento de um descritor de arquivo, que aguarda disponibilidade de leitura.
`loop.add_writer()` | Começa a observar um descritor de arquivo, aguardando por disponibilidade para escrita.
`loop.remove_writer()` | Interrompe o monitoramento de um descritor de arquivo, que aguarda disponibilidade para escrita.

Sinais Unix

`loop.add_signal_handler()` | Adiciona um tratador para um `signal`.
`loop.remove_signal_handler()` | Remove um tratador para um `signal`.

Subprocesso

`loop.subprocess_exec()` | Inicia um subprocesso.
`loop.subprocess_shell()` | Inicia um subprocesso a partir de um comando shell.

Tratamento de erros

`loop.call_exception_handler()` | Chama o tratamento de exceção.
`loop.set_exception_handler()` | Define um novo tratador de exceção.
`loop.get_exception_handler()` | Obtém o tratador de exceção atual.
`loop.default_exception_handler()` | A implementação padrão do tratador de exceção.

Exemplos

- Usando asyncio.get_event_loop() e loop.run_forever().

- Usando loop.call_later().

- Usando `loop.create_connection()` para implementar um cliente-eco.

- Usando `loop.create_connection()` para conectar a um soquete.

- Usando add_reader() para monitorar um descritor de arquivo para eventos de leitura.

- Usando loop.add_signal_handler().

- Usando loop.subprocess_exec().

## Transportes

Todos os transportes implementam os seguintes métodos:

`transport.close()` | Fecha o transporte.
`transport.is_closing()` | Retorna `True` se o transporte estiver fechando ou estiver fechado.
`transport.get_extra_info()` | Solicita informação a respeito do transporte.
`transport.set_protocol()` | Define um novo protocolo.
`transport.get_protocol()` | Retorna o protocolo atual.

Transportes que podem receber dados (TCP e conexões Unix, encadeamentos, etc). Retornado a partir de métodos como `loop.create_connection()`, `loop.create_unix_connection()`, `loop.connect_read_pipe()`, etc:

Realiza leitura de Transportes

`transport.is_reading()` | Retorna `True` se o transporte estiver recebendo.
`transport.pause_reading()` | Pausa o recebimento.
`transport.resume_reading()` | Continua o recebimento.

Transportes que podem enviar dados (TCP e conexões Unix, encadeamentos, etc). Retornado a partir de métodos como `loop.create_connection()`, `loop.create_unix_connection()`, `loop.connect_write_pipe()`, etc:

Realiza escrita de Transportes

`transport.write()` | Escreve dados para o transporte.
`transport.writelines()` | Escreve buffers para o transporte.
`transport.can_write_eof()` | Retorna `True` se o transporte suporta o envio de EOF.
`transport.write_eof()` | Fecha e envia EOF após descarregar dados que estavam no buffer.
`transport.abort()` | Feche o transporte imediatamente.
`transport.get_write_buffer_size()` | Retorna marcas d’agua alta e baixa para controle do fluxo de escrita.
`transport.set_write_buffer_limits()` | Define novas marcas d’agua alta e baixa para controle do fluxo de escrita.

Transporte retornado por `loop.create_datagram_endpoint()`:

Transportes de datagrama

`transport.sendto()` | Envia dados para o par remoto.
`transport.abort()` | Feche o transporte imediatamente.

Abstração de transporte de baixo nível sobre subprocessos. Retornado por `loop.subprocess_exec()` e `loop.subprocess_shell()`:

Transportes de Subprocesso

`transport.get_pid()` | Retorna o process id do subprocesso.
`transport.get_pipe_transport()` | Retorna o transporte para o encadeamento de comunicação requisitada (stdin, stdout, ou stderr).
`transport.get_returncode()` | Retorna o código de retorno do subprocesso.
`transport.kill()` | Mata o subprocesso.
`transport.send_signal()` | Envia um sinal para o subprocesso.
`transport.terminate()` | Interrompe o subprocesso.
`transport.close()` | Mata o subprocesso e fecha todos os encadeamentos.

## Protocolos

Classes de protocolos podem implementar os seguintes métodos de função de retorno:

`callback` `connection_made()` | Chamado quando uma conexão é estabelecida.
`callback` `connection_lost()` | Chamado quanto a conexão é perdida ou fechada.
`callback` `pause_writing()` | Chamado quando o buffer de transporte ultrapassa a marca de nível alto d’agua.
`callback` `resume_writing()` | Chamado quando o buffer de transporte drena abaixo da marca de nível baixo d’agua.

Protocolos de Streaming (TCP, Soquetes Unix, Encadeamentos)

`callback` `data_received()` | Chamado quando algum dado é recebido.
`callback` `eof_received()` | Chamado quando um EOF é recebido.

Protocolos de Streaming Bufferizados

`callback` `get_buffer()` | Chamada para alocar um novo buffer para recebimento.
`callback` `buffer_updated()` | Chamado quando o buffer foi atualizado com os dados recebidos.
`callback` `eof_received()` | Chamado quando um EOF é recebido.

Protocolos de Datagramas

`callback` :meth:`datagram_received() ` | Chamado quando um datagrama é recebido.
`callback` :meth:`error_received() ` | Chamado quando uma operação de envio ou recebimento anterior levanta um `OSError`.

Protocolos de Subprocesso

`callback` `pipe_data_received()` | Chamado quando o processo filho escreve dados no seu encadeamento stdout ou stderr.
`callback` `pipe_connection_lost()` | Chamado quando um dos encadeamentos comunicando com o processo filho é fechado.
`callback` `process_exited()` | Chamado quando o processo filho encerrou.

## Políticas de laço de eventos

Políticas é um mecanismo de baixo nível para alterar o comportamento de funções, similar a `asyncio.get_event_loop()`. Veja também a seção principal de políticas para mais detalhes.

Acessando Políticas

`asyncio.get_event_loop_policy()` | Retorna a política de todo o processo atual.
`asyncio.set_event_loop_policy()` | Define uma nova política para todo o processo.
`AbstractEventLoopPolicy` | Classe base para objetos de política.