rxMethod per le operazioni asincrone
Gestire i flussi asincroni con rxMethod
rxMethod per le operazioni asincrone è una lezione Angular Academy gratuita su CoddyKit. Questa è la lezione 3 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.
Operazioni asincrone in SignalStore
Molte azioni sono asincrone: caricamento dei dati, ricerca con debounce e polling. SignalStore offre rxMethod per gestire questi flussi asincroni reattivi e annullabili.
Nozioni di base su rxMethod
rxMethod crea un metodo basato su una pipeline RxJS. Lo si chiama con un valore, un signal o un Observable, che viene quindi inserito nello stream.
import { rxMethod } from '@ngrx/signals/rxjs-interop';
import { pipe, switchMap, tap } from 'rxjs';
withMethods((store, api = inject(Api)) => ({
load: rxMethod<string>(pipe(
switchMap(id => api.getById(id)),
tap(item => patchState(store, { current: item }))
))
}))Chiamare rxMethod
Lo invochi come un normale metodo, passandogli un valore semplice. Il valore entra nella pipeline definita.
store.load('42');Passare un signal
È possibile passare un signal a un rxMethod. La pipeline viene rieseguita automaticamente ogni volta che il signal cambia: è perfetto per i caricamenti reattivi.
selectedId = signal('1');
ngOnInit() {
this.store.load(this.selectedId); // reloads when selectedId changes
}switchMap annulla le operazioni obsolete
L’uso di switchMap fa sì che una nuova emissione annulli la richiesta precedente ancora in corso. In questo modo si evitano condizioni di gara in cui una vecchia risposta lenta sovrascrive una risposta più recente.
Monitorare lo stato di caricamento
Imposti un flag di caricamento all’inizio e lo azzeri al completamento, così l’interfaccia può mostrare gli indicatori di caricamento.
load: rxMethod<string>(pipe(
tap(() => patchState(store, { loading: true })),
switchMap(id => api.getById(id).pipe(
tap(item => patchState(store, { current: item, loading: false }))
))
))Gestione degli errori
Gli errori devono essere gestiti all’interno della pipeline; altrimenti lo stream termina e il metodo smette di funzionare. Usi catchError all’interno dell’Observable interno.
switchMap(id => api.getById(id).pipe(
tap(item => patchState(store, { current: item, error: null })),
catchError(err => {
patchState(store, { error: err.message, loading: false });
return EMPTY;
})
))Ricerca con debounce
Componga operatori basati sul tempo per la ricerca durante la digitazione. La pipeline applica il debounce e cambia richiesta proprio come in RxJS standard.
search: rxMethod<string>(pipe(
debounceTime(300),
distinctUntilChanged(),
switchMap(q => api.search(q)),
tap(results => patchState(store, { results }))
))Scegliere l’operatore di flattening
Usi switchMap per annullare le operazioni obsolete, concatMap per accodarle, mergeMap per eseguirle in parallelo ed exhaustMap per ignorare le nuove chiamate mentre è occupato. Scelga in base alla concorrenza desiderata.
Pulizia automatica
La sottoscrizione della pipeline è legata al ciclo di vita dello store. Quando lo store viene distrutto, se è limitato al componente, lo stream viene terminato: non si verificano perdite e non è necessario annullare manualmente la sottoscrizione.
Inizializzare alla creazione
Combini rxMethod con la feature withHooks per avviare un caricamento iniziale quando viene creato lo store.
withHooks({
onInit(store) { store.load('initial'); }
})Verifica rapida
Verifichi le sue conoscenze su rxMethod.
Riepilogo
Ha usato rxMethod per i flussi asincroni: lo ha chiamato con valori o signal, ha scelto un operatore di flattening (switchMap per annullare le operazioni obsolete), ha monitorato il caricamento, ha gestito gli errori con catchError e ha fatto affidamento sulla pulizia automatica delle sottoscrizioni.
Domande Frequenti
La lezione «rxMethod per le operazioni asincrone» è gratuita?
Sì — il testo completo di «rxMethod per le operazioni asincrone» è 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 «rxMethod per le operazioni asincrone»?
Gestire i flussi asincroni con rxMethod 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 3 di 4.
Quanto tempo richiede la lezione «rxMethod per le operazioni asincrone»?
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
- Creare un SignalStore
- Computed e metodi
- rxMethod per le operazioni asincrone
- Entità e funzionalità personalizzate