RxSwift for Swift: Complete Guide with Examples

What is RxSwift and Why Do You Need It?

RxSwift is the official implementation of ReactiveX (Reactive Extensions) for the Swift language. ReactiveX is a library for asynchronous programming and data stream manipulation using observable sequences (Observable) and operators (Operators). RxSwift allows you to write clean, declarative, and easily readable code for handling events, asynchronous operations (network requests, UI work, timers), and managing application state.

Why Do You Need RxSwift?

• Simplifying asynchronous code: Instead of nested closures (callback hell) and delegates, RxSwift offers a unified interface for working with any asynchronous data sources.
• Declarative approach: You describe what should happen to the data, not how to implement it. The code becomes more predictable.
• Threading management: Easily switch between background and main threads using the observeOn and subscribeOn operators.
• Composition: You can combine, filter, transform, and merge multiple data streams into one.
• Memory management: Built-in mechanisms (DisposeBag) automatically unsubscribe subscriptions when objects are destroyed, preventing memory leaks.

RxSwift is not just a library, it is a programming paradigm that is especially useful in complex iOS applications with many interactions and states.

Installing RxSwift

RxSwift is installed via CocoaPods or Swift Package Manager (SPM). Installation via pip or npm is not applicable, as it is a native library for the Apple ecosystem.

Installation via CocoaPods

Add to your Podfile:

platform :ios, '13.0'use_frameworks!

target 'YourAppTarget' do  pod 'RxSwift', '~> 6.0'  pod 'RxCocoa', '~> 6.0'  # For UIKit/AppKit integrationend

Then run the command in the terminal:

pod install

Installation via Swift Package Manager (SPM)

In Xcode: File → Add Packages... and paste the repository URL:

https://github.com/ReactiveX/RxSwift.git

Select the desired version (e.g., 6.5.0) and add the RxSwift and RxCocoa packages to your target.

Quick Start with Code Example

Create a simple Observable that emits numbers from 1 to 5, and subscribe to it:

import RxSwift

let disposeBag = DisposeBag()

// 1. Create an Observablelet observable = Observable<Int>.create { observer in    observer.onNext(1)    observer.onNext(2)    observer.onNext(3)    observer.onNext(4)    observer.onNext(5)    observer.onCompleted()    return Disposables.create()}

// 2. Subscribeobservable    .subscribe(        onNext: { value in            print("Received value: \\(value)")        },        onError: { error in            print("Error: \\(error.localizedDescription)")        },        onCompleted: {            print("Sequence completed")        },        onDisposed: {            print("Subscription disposed")        }    )    .disposed(by: disposeBag)

// Output:// Received value: 1// Received value: 2// Received value: 3// Received value: 4// Received value: 5// Sequence completed// Subscription disposed

Explanation:

• Observable.create — creates a custom sequence.
• observer.onNext — emits a new value.
• observer.onCompleted — signals the completion of the sequence.
• s