Një Observable (nga biblioteka RxJS) përfaqëson një rrjedhë vlerash përgjatë kohës të cilën mund ta abonoheni. Angular përdor RxJS në mënyrë të përhapur — kërkesa HTTP, ngjarje rrugash, forma dhe EventEmitter janë të gjitha bazuar në Observable — kështu që kuptimi i tyre është thelbësor.
Promise: a SINGLE future value, eager, can't cancel
Observable: ZERO-to-MANY values over time, lazy (runs on subscribe), CANCELLABLE
Observable-et mund të emetojnë vlera të shumta, ekzekutohen vetëm kur abonoheni dhe mund të paabonoheni (anulohen) — duke i bërë ato ideale për ngjarje, rrjedha dhe HTTP që mund të donit të anulohet.
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
});
Asgjë nuk ndodh derisa .subscribe() — Observable-i është dembel.
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));
Operatorët (të zinxhiruar në .pipe()) transformojnë deklarativisht rrjedhën — debounce, filter, map etj. — duke zgjidhur elegantisht problemet e zakonshme asinkrone (si kërkimi-kur-shkruani).
import { Subscription } from "rxjs";
private sub = new Subscription();
ngOnInit() { this.sub = this.data$.subscribe(...); }
ngOnDestroy() { this.sub.unsubscribe(); } // ❗ prevent leaks
Abonimet manuale duhet të pastrohemi në ngOnDestroy, ose ato vazhdo të punojnë pasi komponenti të ketë shkuar — një rrjedhje kujtese. Zgjidhje të zakonshme: async pipe (paabonohemi automatikisht) ose takeUntilDestroyed().
<!-- ✅ the async pipe handles subscription AND cleanup for you -->
<li *ngFor="let user of users$ | async">{{ user.name }}</li>
Observable-et RxJS janë të endura nëpër Angular — nuk mund ta përdorni HttpClient, forma reaktive ose rrugën pa to.
Kuptimi i abonimit, operatorëve dhe veçanërisht paabonimit (ose përdorimi i async pipe për të shmangur menaxhimin manual) është kritik: është si burimi i fuqisë së Angular-it për të dhëna asinkrone ashtu edhe njëra nga pikat më të zakonshme të tij (rrjedhje nga abonimet e harruara).