Cos'è un observable?

Observable è un'entità che rappresenta un flusso di dati o eventi, che può essere asincrono. Le fonti osservabili possono emettere valori nel corso di un determinato periodo di tempo, e gli abbonati (Subscribers o Observers) possono reagire a questi valori man mano che appaiono.

Concetti chiave:

• Observable (Fonte osservabile): Fonte di dati o eventi.
• Observer (Osservatore): Oggetto con metodi per reagire agli eventi di Observable (next, error, complete).
  • next: Ricezione del valore successivo.
  • error: Si verifica un errore.
  • complete: Fine del flusso di dati.
• Subscription (Abbonamento): Connessione tra Observable e Observer. L’abbonamento si crea chiamando il metodo subscribe su un Observable. Permette all’Observer di ricevere valori e di gestire il ciclo di vita dell’abbonamento (ad esempio, disiscriversi per evitare perdite di memoria).
• Operators (Operatori): Funzioni per trasformare, combinare e gestire i flussi di Observable. Esempi: map, filter, mergeMap, debounceTime.

A differenza delle Promises, gli Observable possono emettere più valori nel tempo, rappresentando flussi di dati piuttosto che un evento asincrono singolo.

Esempio di utilizzo in RxJS (una libreria popolare per la programmazione reattiva):

import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';

// Creazione di un Observable da un array
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Fine del flusso
});

// Abbonamento e utilizzo dell’operatore
const subscription = source.pipe(
  map(value => value * 2) // L’operatore map raddoppia ogni valore
).subscribe({
  next: value => console.log(value), // Riceve i valori: 2, 4, 6
  error: err => console.error(err), // Gestione degli errori
  complete: () => console.log('Complete!') // Fine
});

Vantaggi principali:

• Programmazione reattiva: gestione comoda dei flussi di dati asincroni.
• Componibilità: possibilità di combinare e trasformare facilmente i flussi con operatori.
• Gestione del ciclo di vita: l’abbonamento permette di gestire esplicitamente la ricezione dei dati e di prevenire perdite di memoria.