Observáveis

Observáveis são uma abstração central da programação reativa. Em termos simples, um observável representa uma sequência de valores que podem ocorrer ao longo do tempo, possivelmente de forma assíncrona. Um observável não envia valores por si só; ele precisa de um assinante (observador) para iniciar a emissão. Quando alguém se inscreve, ele recebe notificações sob três tipos de eventos: a emissão de um valor (next), a ocorrência de erro (error) ou a conclusão da sequência (complete).

Observáveis são geralmente lazy, ou seja, a cadeia de operações só começa a produzir valores após a assinatura. Eles podem ser classificados como cold (produzem valores novos para cada assinante) ou hot (compartilham valores entre assinantes). Alguns observáveis também suportam backpressure para controlar a taxa de emissão diante de consumos mais lentos.

As operações sobre observáveis, chamadas operadores, permitem transformar, combinar e controlar fluxos de dados sem alterar a origem. Exemplos comuns incluem map, filter, merge, concat, switchMap e combineLatest. Observáveis são criados de diversas fontes, como eventos de interface, chamadas de rede, temporizadores ou intervalos de tempo.

Para consumir observáveis, os assinantes fornecem manipuladores para os próximos valores, erros e conclusão. Em muitas bibliotecas, como RxJS, a assinatura retorna um objeto de unsubscribe, que encerra a aquisição de dados e libera recursos. Observáveis podem ainda ser estendidos com Subjects, que atuam como observáveis e observadores ao mesmo tempo, facilitando a multicasting e a emissão manual de valores.

Observáveis são fundamentais na programação reativa, especialmente em bibliotecas como Reactive Extensions (Rx) para várias linguagens (RxJS, RxJava, RxSwift). Comparados a Promises, permitem múltiplos valores, composição por meio de operadores e cancelamento explícito, porém exigem uma mentalidade de fluxo de dados contínuo e podem introduzir complexidade.