注意:使用本例中的代码首先应该导入头文件,代码如下:
import RxSwift
介绍
为什么使用 RxSwift?
我们编写的大多数代码都涉及到响应外部事件。当一个用户操纵一个控制(比如用户点击了某个按钮),我们需要写一个 @IBAction
来响应用户的操作。当键盘位置发生改变时,我们需要观察通知以便察觉。当 URL 会话响应了请求,我们必须提供一个闭包来处理数据。还有,我们使用 KVO 模式来发现变量的改变。所有的这些各种各样的模式使我们的代码产生了不必要的复杂。难道没有一种统一的格式来编写我们的调用或者响应代码吗?有,它就是 Rx(响应式编程)。
RxSwift 是 Reactive Extensions (�也叫 Rx)的官方实现, 见 most major languages and platforms。
理解 RxSwfit 的关键是理解 Obserable
“被观察者”这个概念,创造它们,操纵它们,然后订阅它们来响应变化。
一些概念
所有的Observable
(可被观察,可被监听的)实例仅仅是一个 sequence (序列)。
Observable
序列对比 Swift 的 Sequence
的关键优势在于它还可以异步地接收元素。这就是 RxSwift 的本质。 所有的一切只是扩展了这个概念。
- 一个
Observable
(ObservableType
) 相当于一个Sequence
。 -
ObservableType.subscribe(_:)
方法相当于Sequence.makeIterator()
方法。 -
ObservableType.subscribe(_:)
方法使用一个观察者 (ObserverType
) 作为参数,这个方法将会使Observable
被订阅,而观察者则会自动地接收这个Observable
发出的序列事件和元素,而不是在返回的生成器上通过手动调用next()
方法来接收。
如果一个Observable
发出了一个 next 事件 (Event.next(Element)
) ,那么它可以继续发出更多的事件。但是,如果这个Observable
发出一个 error 事件 (Event.error(ErrorType)
)或者一个 completed 事件 (Event.completed
) ,那么接下来这个Observable
序列将不能把除此之外的事件发送到订阅者。
使用序列语法的方式更简单明了的解释这个概念:
next* (error | completed)?
也可以使用图解的方式:
--1--2--3--4--5--6--|----> // "|" = 正常终止
--a--b--c--d--e--f--X----> // "X" = 出现错误而终止
--tap--tap----------tap--> // "|" = 将会继续下去,这是一个按钮轻击序列
上面的这个视图叫做 marble diagrams。你可以在 RxMarbles.com 学到关于 marble diagrams 的更多知识。
Observables and observers(aka subscribers):可被观察的对象和观察者(也叫做订阅者)
Observable
s 不会执行它们的订阅闭包,除非这里有一个订阅者。在下面的这个例子中,Observable
的闭包永远不会执行,因为这里没有订阅者:
example("Observable with no subscribers") {
_ = Observable<String>.create { observerOfString -> Disposable in
print("This will never be printed")
observerOfString.on(.next("😬"))
observerOfString.on(.completed)
return Disposables.create()
}
}
Debug Area 输出:
--- Observable with no subscribers example ---
在下面的这个例子中,当subscribe(_:)
方法被调用后闭包将会被执行。
example("Observable with subscriber") {
_ = Observable<String>.create { observerOfString in
print("Observable created")
observerOfString.on(.next("😉"))
observerOfString.on(.completed)
return Disposables.create()
}
.subscribe { event in
print(event)
}
}
Debug Area 输出:
--- Observable with subscriber example ---
Observable created
next(😉)
completed
你现在不必关心上面例子中创建这些
Obervable
的细节。我们将会在后面详细介绍。
subscribe(_:)
方法返回一个Disposable
实例,这个实例代表一个可支配(可任意处理的;可自由使用的;)的资源,比如一个订阅。这个Disposable
实例在前面的例子中被忽略,但是在通常的时候它应该被妥善的处理。通常的做法是把它添加到一个DisposeBag
(和 autorelease pool 相似)实例中。在之后所有的例子中你都应该加入妥善的处理,因为,嗯,熟能生巧🙂。你可以在 Getting Started guide 项目中的 Disposing section 中学习更多的关于这个处理的知识。