Is ionadaíonn Observable (ó leabharlann RxJS) sruth de bhreisí thar am ar féidir leat a liostaí. Úsáideann Angular RxJS go fairsing — iarrataí HTTP, imeachtaí an ghréasáin, foirmeacha, agus EventEmitter ar fad — tá siad ar bhonn Observable — agus sin an fáth go bhfuil sé riachtanach iad a thuiscint.
Promise: a SINGLE future value, eager, can't cancel
Observable: ZERO-to-MANY values over time, lazy (runs on subscribe), CANCELLABLE
Is féidir le hObservables níos mó ná luach amháin a asthaobhú, níl feidhm acu ach nuair a bhíonn siad intuigthe, agus is féidir teipthe ar siad (cealaithe) — rud a dhéanann siad oiriúnach do imeachtaí, srutha, agus HTTP agus b'fhéidir gur ba bhreá leat a cealú.
import { HttpClient } from "@angular/common/http";
this.http.get<User[]>("/api/users").subscribe({
next: (users) => this.users = users, // each emitted value
error: (err) => console.error(err), // on error
complete: () => console.log("done"), // stream finished
});
Ní tharlaíonn aon rud go dtí go ndéanann tú .subscribe() — tá an Observable mall.
import { map, filter, debounceTime } from "rxjs/operators";
this.searchInput.valueChanges.pipe(
debounceTime(300), // wait for typing to pause
filter(text => text.length > 2), // ignore short queries
map(text => text.trim()), // transform
).subscribe(query => this.search(query));
Claochlaíonn oibreoirí (foluain taobh istigh de .pipe()) an sruth go deimhneach — debounce, scagadh, mapáil, agus mar sin de — réitítear fadhbanna coiteanna neamhshioncronúla (cosúil le cuardach-agus-tú-ag-scríobh) go héifeachtach.
import { Subscription } from "rxjs";
private sub = new Subscription();
ngOnInit() { this.sub = this.data$.subscribe(...); }
ngOnDestroy() { this.sub.unsubscribe(); } // ❗ prevent leaks
Caithfear líostaí láimhe a ghlanadh in ngOnDestroy, nó leanfaidh siad ar an bhfeidhmiú i ndiaidh an chomhpháirt a bheith imithe — díobhála cuimhne. Réitigh choitianta: an async píopa (díshubscríobh go fóill), nó takeUntilDestroyed().
<!-- ✅ the async pipe handles subscription AND cleanup for you -->
<li *ngFor="let user of users$ | async">{{ user.name }}</li>
Tá RxJS Observables fite fuaite trí Angular — ní féidir leat HttpClient, foirmeacha gníomhach, ná an greasan a úsáid gan iad.
Tá sé ríthábhachtach a thuiscint líostaí, oibreoirí, agus go háirithe dí-liostaí (nó an async píopa a úsáid chun bainistiú láimhe a sheachaint): is é an foinse a bhíonn i gcumhacht Angular do shonraí neamhshioncronúla agus is é ceann de na contúirt is coitianta (leagaí ó líostaí dearmhadta).