Observable e sottoscrizioni
Crei e sottoscriva stream observable.
Observable e sottoscrizioni è una lezione Angular Academy gratuita su CoddyKit. Questa è la lezione 1 di 4. Puoi leggere la lezione completa qui gratuitamente — poi esercitati direttamente nel browser con un editor di codice integrato e un tutor IA disponibile 24/7. Fa parte del percorso di apprendimento Angular Academy, e i tuoi progressi si sincronizzano tra il web e l'app CoddyKit. Il corso Angular Academy include 4 lezioni in totale.
Che cos'è un Observable
Un Observable è un flusso lazy di valori nel tempo. Non accade nulla finché non si esegue una subscribe. Può emettere zero o più valori, quindi completarsi oppure generare un errore.
RxJS è la libreria reattiva inclusa in Angular per gestire attività asincrone come richieste HTTP, eventi e timer.
Creare un Observable
Il costruttore di Observable accetta una funzione subscriber. Si chiama next() per emettere un valore, complete() per terminare e error() per segnalare un errore.
import { Observable } from 'rxjs';
const numbers$ = new Observable<number>(subscriber => {
subscriber.next(1);
subscriber.next(2);
subscriber.next(3);
subscriber.complete();
});Sottoscriversi
La sottoscrizione avvia l'esecuzione. Si passi un observer con i gestori next, error e complete.
numbers$.subscribe({
next: v => console.log('value', v),
error: err => console.error(err),
complete: () => console.log('done')
});
// value 1, value 2, value 3, doneGli Observable sono lazy
La funzione subscriber non viene eseguita finché non si chiama subscribe(). Ogni sottoscrizione avvia una nuova esecuzione indipendente (observable cold).
const tick$ = new Observable(s => {
console.log('executing');
s.next(Date.now());
});
// "executing" is NOT logged until subscribe() runsHelper di creazione: of e from
Raramente si utilizza il costruttore. Helper come of e from consentono di creare rapidamente gli observable.
import { of, from } from 'rxjs';
of(10, 20, 30).subscribe(v => console.log(v)); // 10 20 30
from([1, 2, 3]).subscribe(v => console.log(v)); // 1 2 3
from(fetch('/api')).subscribe(res => console.log(res));I creator interval e timer
interval emette numeri incrementali secondo una pianificazione; timer attende e poi emette.
import { interval, timer } from 'rxjs';
interval(1000).subscribe(n => console.log('tick', n));
// 0, 1, 2, ... every second
timer(2000).subscribe(() => console.log('after 2s'));HttpClient restituisce Observable
In Angular, i metodi di HttpClient restituiscono Observable. La richiesta viene inviata solo quando ci si sottoscrive.
import { inject } from '@angular/core';
import { HttpClient } from '@angular/common/http';
const http = inject(HttpClient);
http.get('/api/users').subscribe(users => console.log(users));L'oggetto Subscription
subscribe() restituisce una Subscription. Si chiami unsubscribe() per interrompere la ricezione dei valori e liberare le risorse.
import { interval } from 'rxjs';
const sub = interval(1000).subscribe(n => console.log(n));
// later
sub.unsubscribe(); // stops the streamCompletamento e annullamento della sottoscrizione
Quando un observable esegue complete() o error(), libera automaticamente le risorse. Per i flussi infiniti (interval, eventi DOM) è necessario annullare manualmente la sottoscrizione.
Forma abbreviata di Observer
Se interessano solo i valori, si passi una singola funzione: diventerà il gestore di next.
of(1, 2, 3).subscribe(v => console.log(v));
// equivalent to { next: v => console.log(v) }Hot e cold (in breve)
Gli observable cold iniziano a produrre valori alla sottoscrizione e ogni subscriber ottiene la propria esecuzione (HTTP, of, interval). Gli observable hot producono valori indipendentemente dai subscriber e li condividono (incontreremo i Subjects più avanti).
Verifica rapida
Verifichi la sua comprensione degli observable.
Riepilogo: Observable e Subscription
Un Observable è un flusso lazy che si attiva con subscribe().
- Si emette con next, si termina con complete e si segnala un errore con error.
- I metodi di HttpClient restituiscono observable: la richiesta parte alla sottoscrizione.
- Si annullino le sottoscrizioni ai flussi infiniti per evitare perdite di memoria.
Prossimo argomento: Subject e BehaviorSubject.
Domande Frequenti
La lezione «Observable e sottoscrizioni» è gratuita?
Sì — il testo completo di «Observable e sottoscrizioni» è gratuito qui sul web. Per esercitarvi in modo interattivo (un editor di codice integrato e un tutor IA 24/7) e sbloccare il resto del corso Angular Academy, passa a CoddyKit PRO. Il corso Angular Academy include 4 lezioni in totale.
Cosa imparerò in «Observable e sottoscrizioni»?
Crei e sottoscriva stream observable. Eserciti Angular Academy con codice pratico che esegui direttamente nel browser, e un tutor IA 24/7 risponde alle tue domande mentre lavori sulla lezione.
Ho bisogno di esperienza per iniziare Angular Academy?
Non è richiesta alcuna esperienza precedente. Angular Academy su CoddyKit è strutturato per principianti e studenti avanzati, quindi puoi iniziare da qui o dall'inizio e procedere al tuo ritmo. Questa è la lezione 1 di 4.
Quanto tempo richiede la lezione «Observable e sottoscrizioni»?
La maggior parte delle lezioni CoddyKit richiede circa 5–10 minuti. Ogni lezione è breve e interattiva, quindi fai progressi costanti e riprendi esattamente da dove hai lasciato su web e app.
Posso scrivere ed eseguire codice in questa lezione Angular Academy?
Sì. Ogni lezione Angular Academy include un editor di codice integrato, quindi scrivi ed esegui codice reale direttamente nel tuo browser e ricevi feedback istantaneo dall'IA — nessuna configurazione locale necessaria.
Tutte le lezioni di questo corso
- Observable e sottoscrizioni
- Subject e BehaviorSubject
- Annullamento delle sottoscrizioni e memory leak
- La pipe async