Какие использовал объекты RxSwift?

Использование объектов RxSwift в iOS-разработке

За годы работы с RxSwift я активно использовал практически все ключевые объекты этой реактивной библиотеки, которые можно разделить на несколько основных категорий:

Основные типы Observable

Observable — фундаментальный тип, представляющий асинхронный поток данных:

let stringObservable: Observable<String> = Observable.create { observer in
    observer.onNext("Hello")
    observer.onNext("World")
    observer.onCompleted()
    return Disposables.create()
}

Single — для операций, возвращающих одно значение или ошибку (идеален для сетевых запросов):

func fetchUser(id: Int) -> Single<User> {
    return Single.create { single in
        networkService.fetchUser(id: id) { result in
            switch result {
            case .success(let user):
                single(.success(user))
            case .failure(let error):
                single(.failure(error))
            }
        }
        return Disposables.create()
    }
}

Completable — для операций, которые либо завершаются успешно, либо с ошибкой (без возвращаемого значения):

func saveData() -> Completable {
    return Completable.create { completable in
        database.save { error in
            if let error = error {
                completable(.error(error))
            } else {
                completable(.completed)
            }
        }
        return Disposables.create()
    }
}

Maybe — гибрид Single и Completable (может испустить элемент, завершиться или выдать ошибку):

func findCachedData() -> Maybe<Data> {
    return Maybe.create { maybe in
        if let cached = cacheManager.getData() {
            maybe(.success(cached))
        } else {
            maybe(.completed)
        }
        return Disposables.create()
    }
}

Subjects для управления потоками данных

PublishSubject — испускает элементы только новым подписчикам:

let userUpdates = PublishSubject<User>()
// Новые подписчики получают только будущие обновления

BehaviorSubject — сохраняет и передает текущее значение новым подписчикам:

let currentUser = BehaviorSubject<User>(value: defaultUser)
// Новые подписчики сразу получают текущее значение

ReplaySubject — сохраняет буфер последних N элементов:

let lastMessages = ReplaySubject<Message>.create(bufferSize: 10)
// Сохраняет последние 10 сообщений для новых подписчиков

AsyncSubject — испускает только последний элемент перед завершением:

let finalResult = AsyncSubject<Int>()
// Испускается только конечный результат операции

Операторы для трансформации и комбинирования

Операторы трансформации, которые я часто использовал:

• map и flatMap для преобразования данных
• filter и distinctUntilChanged для фильтрации
• scan для аккумуляции значений
• debounce и throttle для обработки пользовательского ввода

searchTextField.rx.text
    .debounce(.milliseconds(300), scheduler: MainScheduler.instance)
    .distinctUntilChanged()
    .flatMapLatest { query in
        return apiService.search(query: query)
            .catchErrorJustReturn([])
    }
    .bind(to: tableView.rx.items(cellIdentifier: "Cell")) { row, item, cell in
        cell.textLabel?.text = item.title
    }
    .disposed(by: disposeBag)

Schedulers для управления потоками выполнения

MainScheduler — для работы с UI (всегда в главном потоке):

Observable.just(1)
    .subscribe(on: ConcurrentDispatchQueueScheduler(qos: .background))
    .observe(on: MainScheduler.instance)
    .subscribe(onNext: { value in
        // Обновление UI
    })

SerialDispatchQueueScheduler и ConcurrentDispatchQueueScheduler — для фоновых операций:

let backgroundScheduler = ConcurrentDispatchQueueScheduler(
    queue: DispatchQueue.global(qos: .background)
)

Disposables для управления жизненным циклом

DisposeBag — основной инструмент для управления памятью:

class ViewController: UIViewController {
    private let disposeBag = DisposeBag()
    
    override func viewDidLoad() {
        super.viewDidLoad()
        
        viewModel.data
            .bind(to: tableView.rx.items(cellIdentifier: "Cell")) { row, item, cell in
                cell.configure(with: item)
            }
            .disposed(by: disposeBag)
    }
}

CompositeDisposable — для более сложных сценариев управления подписками:

let compositeDisposable = CompositeDisposable()
let disposable1 = observable1.subscribe()
let disposable2 = observable2.subscribe()

_ = compositeDisposable.insert(disposable1)
_ = compositeDisposable.insert(disposable2)

Практическое применение в архитектуре

В реальных проектах я комбинировал эти объекты для создания:

• Реактивных ViewModels с BehaviorRelay для хранения состояния
• Координаторов навигации с использованием PublishSubject для событий навигации
• Сетевых слоев с Single и Observable для запросов
• Локальных хранилищ с ReplaySubject для кэширования данных
• Обработки пользовательского ввода через комбинацию ControlProperty и операторов

Driver и Signal из RxCocoa стали незаменимыми для работы с UI, так как они гарантированно выполняются в главном потоке и не генерируют ошибки, что критично для пользовательского интерфейса.

Каждый из этих объектов выбирается исходя из конкретной задачи: Single для однократных операций, Observable для потоков данных, BehaviorSubject для состояния, которое должно быть доступно новым подписчикам. Понимание различий и особенностей каждого типа позволяет создавать эффективные, поддерживаемые и отзывчивые приложения.