RxSwift — bu nədir, imkanları və reaktiv proqramlaşdırma

RxSwift nədir?

RxSwift — 2012-ci ildə Microsoft tərəfindən .NET üçün yaradılmış ReactiveX (Rx) kitabxanasının Swift portudur. Rx-in əsas ideyası — hər hansı asinxron verilən mənbəyini funksional operatorlar tətbiq oluna bilən Observable ardıcıllığı kimi təqdim etməkdir. iOS inkişafında RxSwift açıq deleqatlar və target-action olmadan UI hadisələrini (dümə basılması, mətn daxil etmə, jestlər) tətbiq məntiqi ilə əlaqələndirmək üçün istifadə olunur.

Kitabxana üç moduldan ibarətdir: RxSwift (özək — Observable, Operator, Scheduler), RxCocoa (UIKit ilə inteqrasiya — UIButton, UITextField, UITableView üçün rx-əlavələr) və RxRelay (terminal hadisələrsiz Subject). Bu bölgü server Swift-də və testlərdə özəkdən istifadə etməyə, UI bağlantısını yalnız iOS tətbiqləri üçün qoşmağa imkan verir.

Stack Overflow, 2025 sorğusuna görə, RxSwift iOS üçün ən çox istifadə olunan üçüncü tərəf kitabxanalarının ilk 5-liyinə daxildir. Populyarlığın əsas səbəbi bütün asinxron nümunələrin vahid şəkildə işlənməsidir: URLSession vasitəsilə şəbəkə sorğuları, UIViewPropertyAnimator ilə animasiyalar, NotificationCenter ilə bildirişlər və DelegateProxy ilə deleqatlar — bütün bunlar proqnozlaşdırıla bilən həyat dövrü olan Observable-a endirilir.

Reaktiv proqramlaşdırma fəlsəfəsi

Reaktiv proqramlaşdırma — proqramın məlumatları sorğulamaq əvəzinə onların dəyişikliklərinə reaksiya verdiyi bir paradiqmadır. “Məlumatları al → emal et → UI-nı yenilə” yazmaq əvəzinə, proqramçı çevirmə zəncirini təsvir edir: “məlumatlar dəyişəndə, filtr tətbiq et, sonra map, sonra UI-nı yenilə”. RxSwift bu paradiqmanı tənbel icra ilə Observable zənciriləri vasitəsilə həyata keçirir — abunəçi görünənə qədər heç nə baş vermir.

RxSwift-in əsas komponentləri: Observable, Subject, Disposable

Observable — RxSwift-in əsas tipi, zaman içərisində hadisələr ardıcıllığını təmsil edir. Observable üç növ hadisə göndərə bilər: next (yeni dəyər), error (səhv, axını bitirir) və completed (uğurlu tamamlanma). Finite Observable (bütün dəyərləri göndərdikdən sonra bitir) və infinite Observable (məs. UI hadisələri — heç vaxt bitmir) mövcuddur.

Observable və onun həyat dövrü

Həyat dövrü Observable üç mərhələni əhatə edir: yaratma (create, just, from), çevirmə (map, filter, flatMap operatorları) və abunə (subscribe). Abunə olmadan Observable heç bir hərəkət yerinə yetirmir — bu tənbel ardıcıllıqdır. Abunədən sonra Observable bitənə və ya abunəçi Disposable vasitəsilə abunəni ləğv edənə qədər hadisələr göndərir.

import RxSwift

// Massivdən Observable yaratma
let numbers = Observable.from([1, 2, 3, 4, 5])

// Operatorlar vasitəsilə çevirmə
let squared = numbers
    .filter { $0 % 2 == 0 }
    .map { $0 * $0 }

// Hadisə emalı ilə abunə
let disposable = squared
    .subscribe(onNext: { print($0) },
               onError: { print("Error: \($0)") },
               onCompleted: { print("Done") })

Subject — eyni anda Observable (abunə olmaq olar) və Observer (hadisə göndərmək olar) olan tipdir. RxSwift dörd növ Subject təmin edir: PublishSubject (yalnız yeni hadisələr), BehaviorSubject (ilkin dəyərlə), ReplaySubject (son N hadisənin buferləşməsi) və AsyncSubject (bitməzdən əvvəl yalnız son dəyər). Subject imperativ kodu (köməkçürələr, deleqatlar) reaktiv zəncirə inteqrasiya etmək üçün əlverişlidir.

Disposable — abunənin ləğvi tokenidir. Abunəçi hadisələri artıq qəbul etmək istəmədikdə, disposable.dispose() çağırır. Praktikada DisposeBag istifadə olunur: sahibinin deinitsializasiyası zamanı (məs. UIViewController) bütün abunələri avtomatik ləğv edən Disposable kolleksiyası. Bu, abunələrin əllə idarə edilməsi zamanı qaçınılmaz olan yaddaş sızıntılarının qarşısını alır.

Axın çevirmə və filtrləmə operatorları

Operatorlar RxSwift — bir Observable qəbul edib məlumat axınını çevirərək başqa Observable qaytaran funksiyalardır. Operatorları birləşdirərək, proqramçı aralıq dəyişənlər və rəqib vəziyyətləri olmadan deklarativ emal zənciriləri qurur. Bütün operatorlar tənbeldir: zəncir təsvir zamanı qurulur, abunə zamanı icra olunur.

Çevirmə operatorları axındakı hər hadisəni dəyişdirir. map hər elementə funksiya tətbiq edir, flatMap hər elementdən Observable-ı bir düz axına açır, scan aralıq nəticəni toplayır (reduce analoqu, lakin hər addımda emissiya ilə). buffer elementləri zamana və ya sayına görə qruplaşdırır, window axını pəncərələr üzrə iç-içə Observable-lara bölür.

// Operator zəncirinə nümunə: debounce ilə axtarış
searchTextField.rx.text
    .orEmpty
    .debounce(.milliseconds(300), scheduler: MainScheduler.instance)
    .distinctUntilChanged()
    .flatMapLatest { query -> Observable<[String]> in
        return apiService.search(query)
    }
    .bind(to: tableView.rx.items(cellIdentifier: "Cell")) { _, item, cell in
        cell.textLabel?.text = item
    }
    .disposed(by: disposeBag)

Filtrləmə operatorları yalnız şərtə uyğun hadisələri buraxır. filter predikata görə ayırır, distinctUntilChanged əvvəlkindən fərqli dəyərləri buraxır, take və takeWhile hadisələrin sayını məhdudlaşdırır. skip və skipWhile ilk N hadisəni və ya şərt yerinə yetirilənə qədərki hadisələri atlayır. Səhvlərin idarə edilməsi üçün catchError (tutma və əvəz etmə) və retry (səhvdə ardıcıllığı təkrarlama) istifadə olunur.

Birləşdirmə operatorları bir neçə Observable-ı birinə birləşdirir. combineLatest bir neçə axından son dəyərləri kortejdə birləşdirir, zip eyni indeksli elementləri cütləyir, merge bir neçə axını hadisələrin gəliş ardıcıllığı ilə birləşdirir. withLatestFrom əsas axından hadisəni başqa axının son dəyəri ilə birləşdirir — cari vəziyyətlə UI hadisələri üçün əlverişlidir.

Schedulers və icra ipliklərinin idarə edilməsi

Scheduler RxSwift-də — icra ipliyi (və ya növbə) üzərində abstraksiyadır. Scheduler hadisələrin yaradılması, çevrilməsi və abunəsinin hansı iplikdə yerinə yetiriləcəyini müəyyənləşdirir. GCD-dən fərqli olaraq, proqramçı açıqşəkil DispatchQueue göstərir, RxSwift iki parametr istifadə edir: subscribeOn (Observable-in işlədiyi iplik) və observeOn (abunəçinin çağırıldığı iplik).

MainScheduler və BackgroundScheduler

MainScheduler kodu əsas iplikdə icra edir — UIKit yenilənməsi üçün məcburidir (bütün UI dəyişiklikləri main thread-da baş verməlidir). SerialDispatchQueueScheduler ardıcıl GCD növbəsini, ConcurrentDispatchQueueScheduler paralel növbəni örtür. Fon tapşırıqları üçün qos: .background və ya .utility ilə ConcurrentDispatchQueueScheduler istifadə olunur.

// Tipik nümunə: fon işi + main-də UI
apiService.fetchData()
    .subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
    .observeOn(MainScheduler.instance)
    .subscribe(onNext: { data in
        self.tableView.reloadData()
        self.loadingIndicator.stopAnimating()
    })
    .disposed(by: disposeBag)

Scheduler-in düzgün istifadəsi şəbəkə sorğuları və ağır hesablamalar zamanı UI bloklanmasının qarşısını alır. subscribeOn bütün yuxarı axına təsir edir (observeOn-ə qədər bütün operatorlar göstərilən planlayıcıda icra olunur). observeOn aşağı axını dəyişdirir — observeOn-dan sonrakı bütün operatorlar göstərilən planlayıcıda icra olunur. Zəncirdə müxtəlif çevirmə mərhələlərində ipliklər arasında keçid üçün bir neçə observeOn ola bilər.

SerialDispatchQueueScheduler hadisələrin ardıcıl emalını təmin edir ki, bu da ortaq resursların iplik təhlükəsizliyi üçün vacibdir. Yüksək yüklü əməliyyatlar (şəkillərin emalı, JSON-un pars edilməsi) üçün ConcurrentDispatchQueueScheduler istifadə edin — RxSwift bir Observable daxilində hadisələrin sırasını qoruyacaq, lakin müxtəlif Observable-lar paralel işlənə bilər.

iOS-da RxSwift-in praktiki tətbiqi

RxSwift iOS layihələrində ən çox UI-nı məlumatlarla reaktiv zəncirilər vasitəsilə əlaqələndirmək üçün istifadə olunur. RxCocoa bütün standart UIKit komponentləri üçün rx-əlavələr təmin edir: UIButton üçün rx.tap, UITextField üçün rx.text, UIPickerView üçün rx.selectedRow. Bu, @IBAction və deleqatlardan imtina etməyə, onları deklarativ abunələrlə əvəz etməyə imkan verir.

RxSwift MVVM ilə birlikdə

MVVM (Model-View-ViewModel) — ViewModel-in vəziyyət və biznes məntiqini idarə etdiyi, View-in isə ViewModel-in reaktiv xüsusiyyətlərinə abunə olduğu memarlıq nümunəsidir. RxSwift MVVM-ə mükəmməl uyğunlaşır: ViewModel məlumatlar üçün Observable və ya Driver nəşr edir, View isə onlara bind vasitəsilə abunə olur. ViewModel-in View-a istinadı yoxdur — o, View-in istifadə etdiyi Observable qaytarır.

class LoginViewModel {
    let email = BehaviorRelay<String>(value: "")
    let password = BehaviorRelay<String>(value: "")

    var isFormValid: Observable<Bool> {
        return Observable
            .combineLatest(email, password) {
                !$0.isEmpty && $0.contains("@") && $1.count >= 6
            }
    }
}

// ViewController-də:
viewModel.isFormValid
    .bind(to: loginButton.rx.isEnabled)
    .disposed(by: disposeBag)

Şəbəkə sorğuları — RxSwift-in ikinci ən çox istifadə sahəsidir. URLSession.rx.response HTTP sorğusunu uğurda (response, data) və ya uğursuzluqda error qaytaran Observable-ı örtür. Codable və map operatoru ilə birlikdə yığcam reaktiv API qatı alınır: hər metoddan callback və səhv idarəsi olmadan Observable<MyModel>. Şəbəkə xətası zamanı retry(3) operatoru sorğunu eksponensial gecikmə ilə üç dəfə avtomatik təkrarlayır.

RxSwift vs Combine

Combine — iOS 13-də təqdim edilmiş yerli Apple freymvorkudur. RxSwift ilə eyni vəzifələri həll edir: Publisher, Subscriber və operatorlar vasitəsilə asinxron hadisələrlə işləmə. Lakin Combine-in əsas fərqləri var: Failure tipi vasitəsilə səhvlərin ciddi tipləşdirilməsi, Swift Concurrency (async/await) üçün daxili dəstək və @Published və ObservableObject vasitəsilə SwiftUI ilə inteqrasiya.

RxSwift geriyə uyğunluqda qazanır — iOS 8+-i dəstəkləyir, Combine isə iOS 13+ tələb edir. RxSwift daha zəngin üçüncü tərəf əlavələr ekosisteminə (RxDataSources, RxGesture, RxAnimated) və operatorlar üzrə ətraflı sənədləşdirməyə malikdir. Köhnə iOS versiyalarını dəstəkləyən layihələr üçün RxSwift yeganə seçim olaraq qalır.

iOS 13+ olan yeni layihələr üçün Apple Combine-i tövsiyə edir. SwiftUI ilə sıx inteqrasiya olunub, daha kiçik binar ölçüsü və rəsmi dəstəyə malikdir. Lakin mövcud RxSwift kodunun Combine-ə miqrasiyası bütün Observable → Publisher-lərin yenidən yazılmasını tələb edir və RxCocoa ekosisteminin Combine-də tam analoqu yoxdur — UIKit bütün UI komponentləri üçün yerli Publisher-lərə malik deyil.