0 added
0 removed
Original
2026-01-01
Modified
2026-03-10
1
<p>В этой заметке мы рассмотрим некоторые методы, используемые при создании Observable в RxSwift. Observable - наблюдаемый объект или то, что будет отдавать данные. Если говорить о парадигме реактивного программирования на iOS с помощью фреймворка RxSwift, то Observable нужен для генерации потока данных.</p>
1
<p>В этой заметке мы рассмотрим некоторые методы, используемые при создании Observable в RxSwift. Observable - наблюдаемый объект или то, что будет отдавать данные. Если говорить о парадигме реактивного программирования на iOS с помощью фреймворка RxSwift, то Observable нужен для генерации потока данных.</p>
2
<h2>asObservable</h2>
2
<h2>asObservable</h2>
3
<p>Данный метод реализован в классах RxSwift, когда они поддерживают конвертацию в Observable. К примеру: ControlProperty, Variable, ControlEvent, Driver.</p>
3
<p>Данный метод реализован в классах RxSwift, когда они поддерживают конвертацию в Observable. К примеру: ControlProperty, Variable, ControlEvent, Driver.</p>
4
example("\"asObservable\"") { let variable = Variable(0) variable .asObservable() .subscribe({ event in print(event) }) variable.value = 1 }<p>Вывод в консоли будет следующим:</p>
4
example("\"asObservable\"") { let variable = Variable(0) variable .asObservable() .subscribe({ event in print(event) }) variable.value = 1 }<p>Вывод в консоли будет следующим:</p>
5
--- "asObservable" example --- next(0) next(1) completed<p>В нашем примере мы преобразовали Variable в Observable, а также подписались на его события.</p>
5
--- "asObservable" example --- next(0) next(1) completed<p>В нашем примере мы преобразовали Variable в Observable, а также подписались на его события.</p>
6
<h2>create</h2>
6
<h2>create</h2>
7
<p>Следующий метод даёт возможность разработчику создавать Observable с нуля. При этом разработчик полностью контролирует, какие именно элементы он будет генерировать и когда.</p>
7
<p>Следующий метод даёт возможность разработчику создавать Observable с нуля. При этом разработчик полностью контролирует, какие именно элементы он будет генерировать и когда.</p>
8
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) }) }<p>Смотрим консоль:</p>
8
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) }) }<p>Смотрим консоль:</p>
9
--- "create" example --- next(1) next(2) next(A) next(B) completed<p>Таким образом, мы только что создали Observable. Он, в свою очередь, сгенерирует несколько значений. В конце будет вызван complete.</p>
9
--- "create" example --- next(1) next(2) next(A) next(B) completed<p>Таким образом, мы только что создали Observable. Он, в свою очередь, сгенерирует несколько значений. В конце будет вызван complete.</p>
10
<h2>deferred</h2>
10
<h2>deferred</h2>
11
<p>Данный оператор даёт возможность отложить создание Observable вплоть до момента подписки посредством subscribe.</p>
11
<p>Данный оператор даёт возможность отложить создание Observable вплоть до момента подписки посредством subscribe.</p>
12
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) }) }<p>Консоль:</p>
12
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) }) }<p>Консоль:</p>
13
--- without "deferred" example --- next(1) completed --- with "deferred" example --- next(2) completed<p>В первом случае Observable будет создан сразу посредством Observable.just(i), а изменение значения i уже не повлияет на элемент, генерируемый этой последовательностью. Что касается второго случая, то тут мы создадим Observable, используя deferred, при этом у нас есть возможность поменять значение i перед subscribe.</p>
13
--- without "deferred" example --- next(1) completed --- with "deferred" example --- next(2) completed<p>В первом случае Observable будет создан сразу посредством Observable.just(i), а изменение значения i уже не повлияет на элемент, генерируемый этой последовательностью. Что касается второго случая, то тут мы создадим Observable, используя deferred, при этом у нас есть возможность поменять значение i перед subscribe.</p>
14
<p><em><a>Источник</a></em></p>
14
<p><em><a>Источник</a></em></p>
15
15