Создание Observable в RxSwift | OTUS
⚡ Подписка на курсы OTUS!
Интенсивная прокачка навыков для IT-специалистов!
Подробнее

Курсы

Программирование
Python Developer. Professional
-3%
Разработчик на Spring Framework
-5%
iOS Developer. Professional
-8%
Golang Developer. Professional
-6%
Базы данных
-12%
Agile Project Manager
-5%
Android Developer. Professional
-11%
Microservice Architecture
-5%
C++ Developer. Professional
-5%
Highload Architect
-6%
JavaScript Developer. Basic
-8%
Backend-разработчик на PHP
-9%
Архитектура и шаблоны проектирования C# Developer. Professional
-9%
Team Lead
-6%
Kotlin Backend Developer
-9%
Разработчик программных роботов (RPA) на базе UiPath и PIX Unity Game Developer. Basic Разработчик голосовых ассистентов и чат-ботов Node.js Developer Интенсив «Оптимизация в Java» Супер - интенсив по паттернам проектирования Супер - интенсив по Kubernetes iOS Developer. Basic Супер-интенсив «СУБД в высоконагруженных системах» Супер-интенсив "Tarantool"
Инфраструктура
DevOps практики и инструменты
-12%
Базы данных
-12%
Network engineer. Basic
-10%
Network engineer
-4%
Инфраструктурная платформа на основе Kubernetes
-6%
Экспресс-курс по управлению миграциями (DBVC)
-10%
Мониторинг и логирование: Zabbix, Prometheus, ELK
-10%
Administrator Linux. Professional
-6%
Разработчик IoT
-13%
Основы Windows Server Cloud Solution Architecture Разработчик голосовых ассистентов и чат-ботов VOIP инженер Супер-практикум по работе с протоколом BGP NoSQL Супер-практикум по использованию и настройке GIT Супер-интенсив «СУБД в высоконагруженных системах» Экспресс-курс «IaC Ansible»
Специализации Курсы в разработке Подготовительные курсы
+7 499 938-92-02

Создание Observable в RxSwift

В этой заметке мы рассмотрим некоторые методы, используемые при создании Observable в RxSwift. Observable — наблюдаемый объект или то, что будет отдавать данные. Если говорить о парадигме реактивного программирования на iOS с помощью фреймворка RxSwift, то Observable нужен для генерации потока данных.

asObservable

Данный метод реализован в классах RxSwift, когда они поддерживают конвертацию в Observable. К примеру: ControlProperty, Variable, ControlEvent, Driver.

example("\"asObservable\"") {
    let variable = Variable(0)
    variable
        .asObservable()
        .subscribe({ event in
            print(event)
        })
    variable.value = 1
}

Вывод в консоли будет следующим:

--- "asObservable" example ---
next(0)
next(1)
completed

В нашем примере мы преобразовали Variable в Observable, а также подписались на его события.

create

Следующий метод даёт возможность разработчику создавать Observable с нуля. При этом разработчик полностью контролирует, какие именно элементы он будет генерировать и когда.

example("\"create\"") {
    Observable
        .create({ observer in
            observer.on(.next(1))
            observer.on(.next(2))
            observer.on(.next("A"))
            observer.on(.next("B"))
            observer.onCompleted()
            return Disposables.create()
        })
        .subscribe({ event in
            print(event)
        })
}

Смотрим консоль:

--- "create" example ---
next(1)
next(2)
next(A)
next(B)
completed

Таким образом, мы только что создали Observable. Он, в свою очередь, сгенерирует несколько значений. В конце будет вызван complete.

deferred

Данный оператор даёт возможность отложить создание Observable вплоть до момента подписки посредством subscribe.

example("without \"deferred\"") {
    var i = 1
    let observable = Observable.just(i)
    i = 2
    observable
        .subscribe({ event in
            print(event)
        })
}

example("with \"deferred\"") {
    var i = 1
    let observable = Observable.deferred({ Observable.just(i) })
    i = 2
    observable
        .subscribe({ event in
            print(event)
        })
}

Консоль:

--- without "deferred" example ---
next(1)
completed

--- with "deferred" example ---
next(2)
completed

В первом случае Observable будет создан сразу посредством Observable.just(i), а изменение значения i уже не повлияет на элемент, генерируемый этой последовательностью. Что касается второго случая, то тут мы создадим Observable, используя deferred, при этом у нас есть возможность поменять значение i перед subscribe.

Источник

Не пропустите новые полезные статьи!

Спасибо за подписку!

Мы отправили вам письмо для подтверждения вашего email.
С уважением, OTUS!

Автор
0 комментариев
Для комментирования необходимо авторизоваться