注意：使用本例中的代码首先应该导入头文件，代码如下：
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):可被观察的对象和观察者（也叫做订阅者）
Observables 不会执行它们的订阅闭包，除非这里有一个订阅者。在下面的这个例子中，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 中学习更多的关于这个处理的知识。
网友评论