რა არის Observable და როგორ იყენებს Angular-ი RxJS-ს?

Question

Accepted Answer

**Observable** (**RxJS** ბიბლიოთეკიდან) წარმოადგენს **მნიშვნელობების ნაკადს დროის განმავლობაში**, რომელზეც ხელმისაწვდომი უჯდებით. Angular იყენებს RxJS-ს ფართოდ — HTTP მოთხოვნები, როუტერის ხდომილებები, ფორმები და `EventEmitter` ყველა Observable-ზე დაფუძნებული — ამიტომ მათი გაგება აუცილებელია. ## Observable vs Promise ```text Promise: a SINGLE future value, eager, can't cancel Observable: ZERO-to-MANY values over time, lazy (runs on subscribe), CANCELLABLE ``` Observable-ი შეიძლება გააქეზოს მრავალი მნიშვნელობა, აკრძალოს მხოლოდ როდესაც დაემზადოთ, და შეიძლება მოხდეს გამოწერა (გაუქმება) — ეს მათ იდეალურს ხდის ხდომილებებისთვის, ნაკადებისთვის და HTTP-სთვის, რომელიც შეიძლება გინდოდეთ გაუქმება. ## გამოწერა ```ts import { HttpClient } from "@angular/common/http"; this.http.get("/api/users").subscribe({ next: (users) => this.users = users, // each emitted value error: (err) => console.error(err), // on error complete: () => console.log("done"), // stream finished }); ``` აფერი ხდება არ მიმდინარეობს `.subscribe()` არ დასვამდე — Observable-ი ზეწკითელი. ## ოპერატორები ამ ნაკადებს გარდაქმნიან ```ts 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)); ``` ოპერატორები (რომლებიც დაკავშირებულია `.pipe()`-ში) დეკლარაციულად გარდაქმნიან ნაკადს — debounce, filter, map და ა.შ. — გადაჭრიან საერთო async პრობლემებს (როგორიცაა ძიება ხელმისაწვდომი აკრეფის დროს) ელეგანტურად. ## მეხსიერების გაჟონვის საფრთხე: unsubscribe ```ts import { Subscription } from "rxjs"; private sub = new Subscription(); ngOnInit() { this.sub = this.data$.subscribe(...); } ngOnDestroy() { this.sub.unsubscribe(); } // ❗ prevent leaks ``` ხელით გამოწერა უნდა იყოს დაკითხული `ngOnDestroy`-ში, ან კი იტაქებენ აქტივობას მას შემდეგ, რაც კომპონენტი წაბნა — ეს მეხსიერების გაჟონვაა. საერთო გამოსავალი: **`async` pipe** (თვითგამოწერა), ან `takeUntilDestroyed()`. ```html

``` ## რატომ მნიშვნელოვნია RxJS Observable-ები არის ყოვლისკენ დაკვრული Angular-ში — არ შეგიძლია გამოიყენო HttpClient, რეაქტიული ფორმები ან როუტერი მათ გარეშე. გამოწერის, ოპერატორებისა და განსაკუთრებით **გამოწერის გაუქმება** (ან `async` pipe-ის გამოყენება ხელით მართვის თავიდან აცილებაზე) კრიტიკულია: ეს არის Angular-ის ძლიერების წყარო async მონაცემებისთვის და ასევე მისი ყველაზე გავრცელებული ხელყოფა (გაჟონვა დავიწყებული გამოწერებიდან).