为什么要学RXSwift?
有产生这个疑问的同学，请先看下图
试问，这么牛逼的框架不值得去研究一番嘛？？？
(贴心奉上)点了我，爱上我
决定要去做一件事，至少要知道原因，或者是需要一份动力。RXSwift官网上列举了一些例子简单告诉了我们RXSwift具备了哪些能力，比如说：
- 它可以统一处理
Delegate,KVO,Notification - 它可以绑定UI
- 方便网络请求的处理
等等一系列能力......
但这些也只是描述了可以用RXSwift可以来做什么，而我们更关注的是为什么要选择RXSwift?
关于这一点我们需要分析下GUI 编程的本质
GUI可以抽象为视图和数据的结合
视图负责两件事：展示和交互，而展示什么由数据决定！
上图可以看到RxSwift可以在UniDirectional Data Flow的各个阶段都发挥作用，从而让Data 的处理和流动更加简洁和清晰！
具体解释如下：
- 通过对
RxCocoa的各种回调进行统一处理，方便了「Interact」的处理。 - 通过对
Observable的transform和composite，方便了「Action」的生成（比如使用throttle来压缩Action）。 - 通过对网络请求以及其他异步数据的获取进行
Observable封装，方便了异步数据的处理。 - 通过
RxCocoa的binding，方便了数据的渲染。
综上我们能看到
RxCocoa规范了数据流，RxSwift为数据的处理提供了方便，这两个类库的结合，可以产生清晰的架构和易维护的代码
RXSwift所为何物？
在说RxSwift之前，先来说下Rx， ReactiveX 是一种编程模型，最初由微软开发，结合了观察者模式、迭代器模式和函数式编程的精华，来更方便地处理异步数据流。其中最重要的一个概念是 Observable。
在这里有个比较好的例子帮助理解这个Observable
“举个简单的例子，当别人在跟你说话时，你就是那个观察者，别人就是那个 Observable，它有几个特点：
- 可能会不断地跟你说话。（
onNext:）- 可能会说错话。（
onError:）- 结束会说话。（
onCompleted）你在听到对方说的话后，也可以有几种反应：
- 根据说的话，做相应的事，比如对方让你借本书给他。（
subscribe）- 把对方说的话，加工下再传达给其他人，比如对方说小张好像不太舒服，你传达给其他人时就变成了小张失恋了。（
map:）- 参考其他人说的话再做处理，比如 A 说某家店很好吃，B 说某家店一般般，你需要结合两个人的意见再做定夺。（
zip:）”
在这里核心是当数据有变化时，能够立刻知晓，并且通过组合和转换后，可以即时作出响应。
RXSwift工作流？
在了解了RXSwift后，我们自然而然的就会想它具体的工作流程是什么呢？
其实大致可以分为这么几个阶段：
-
先把
Native Object变成Observable
| -
通过
Observable内置的各种强大的转换和组合能力变成新的Observable
| - 最后消费新的
Observable的数据
可以参考下图来理解：
Native Object -> Observable
-
rx extension
可以说“万物皆可RX”，直接上图
看到这里，无需多言了吧。。
Observable.create
通过这个方法，可以将 Native object 包装成 Observable
public static func create(_ subscribe: @escaping (AnyObserver<E>) -> Disposable) -> Observable<E> {
return AnonymousObservable(subscribe)
}
-
Variable()
Variable(value)可以把value变成一个Observable
我们可以点击到它里面看一下
public final class Variable<Element> {
public typealias E = Element
private let _subject: BehaviorSubject<Element>
private var _lock = SpinLock()
// state
private var _value: E
#if DEBUG
fileprivate let _synchronizationTracker = SynchronizationTracker()
#endif
/// Gets or sets current value of variable.
///
/// Whenever a new value is set, all the observers are notified of the change.
///
/// Even if the newly set value is same as the old value, observers are still notified for change.
public var value: E {
get {
self._lock.lock(); defer { self._lock.unlock() }
return self._value
}
set(newValue) {
#if DEBUG
self._synchronizationTracker.register(synchronizationErrorMessage: .variable)
defer { self._synchronizationTracker.unregister() }
#endif
self._lock.lock()
self._value = newValue
self._lock.unlock()
self._subject.on(.next(newValue))
}
}
/// Initializes variable with initial value.
///
/// - parameter value: Initial variable value.
public init(_ value: Element) {
#if DEBUG
DeprecationWarner.warnIfNeeded(.variable)
#endif
self._value = value
self._subject = BehaviorSubject(value: value)
}
/// - returns: Canonical interface for push style sequence
public func asObservable() -> Observable<E> {
return self._subject
}
deinit {
self._subject.on(.completed)
}
}
就会发现是它通过 subject来做的，大意是把 value存到一个内部变量_value 里，当调用 value方法时，先更新_value值，然后调用内部的_subject.on(.next(newValue))方法告知 subscriber
- Subject
Subject简单说是一个可以主动发射数据的Observable，多了 onNext(value), onError(error), ‘onCompleted’方法!
let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
subject.addObserver("1").addDisposableTo(disposeBag)
subject.onNext("AAA")
subject.onNext("BBB")
subject.addObserver("2").addDisposableTo(disposeBag)
subject.onNext("😁😁😁")
subject.onNext("😝😝😝")
Subject还是建议少用，虽然官方并没有提及，但因为在以前使用RAC的时候，Subject因其本身功能太过强大，不好控制，成了一个不太推荐使用的功能，
- Observable -> New Observable
Observable----(修改／过滤／组合等操作)---->New Observable
换言之，Observable可以随心所欲构造自己想要的数据~！
Combine
Combine就是把多个Observable组合起来使用Transform
对一个Observable的数值做一些小改动，产出新的值，依是Observable
let disposeBag = DisposeBag()
Observable.of(1, 2, 3)
.map { $0 * $0 }
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
-
Filter
Filter的作用是对Observable传过来的数据进行过滤，只有符合条件的才有资格被subscribe
结语
上面只是简单介绍了RXSwift相关的一些基本概念，其实这些如果理清楚了，你会发现RXSwift并不难（尤其是具备RAC开发经验的），要习惯多去从Observable的角度分析思考问题，慢慢的就会领略到函数响应式编程的真正魅力了，同时自身的抽象能力和代码可读性都会有提升。
学习技术我个人觉得掌握其核心思想最重要，因为它是可以提升你个人认知能力的~！
这不仅仅可以帮助你解决技术问题，也可以在你生活中遇到问题时，提供解决思路~！
