RxSwift 生态系统 - 图3 RxSwift 生态系统

RxCocoa 给 UI框架 提供了 Rx 支持，让我们能够使用按钮点击序列，输入框当前文本序列等。不过 RxCocoa 也只是 RxSwift 生态系统 中的一员。RxSwift 生态系统还给其他框架提供了 Rx 支持：

RxDataSources

书写 tabelView 或 collectionView 的数据源是一件非常繁琐的事情，有一大堆的代理方法需要被执行。 RxDataSources 可以帮助你简化这一过程。你可以用它来布局多层级的列表页，并且它还可以提供动画支持。

RxSwift 生态系统 - 图4

你只需要几行代码就可以布局一个多 Section 的 tabelView：

  1. let dataSource = RxTableViewSectionedReloadDataSource<SectionModel<String, Int>>()
  2. Observable.just([SectionModel(model: "title", items: [1, 2, 3])])
  3.     .bind(to: tableView.rx.items(dataSource: dataSource))
  4.     .disposed(by: disposeBag)

你可以点击 RxDataSources 来了解更多信息。

RxAlamofire

Alamofire 是一个非常流行的网络请求框架。RxAlamofire 是用 RxSwift 封装的 Alamofire。它使得网络请求调用变得更加平滑，处理请求结果变得更简洁，更高效：

  1. let stringURL = ""
  3. // 使用 NSURLSession
  4. let session = NSURLSession.sharedSession()
  6. _ = session.rx
  7.         .json(.get, stringURL)
  8.         .observeOn(MainScheduler.instance)
  9.         .subscribe { print($0) }
  11. // 使用 Alamofire 引擎
  13. _ = json(.get, stringURL)
  14.     .observeOn(MainScheduler.instance)
  15.     .subscribe { print($0) }
  17. // 使用 Alamofire manager
  19. let manager = Manager.sharedInstance
  21. _ = manager.rx.json(.get, stringURL)
  22.     .observeOn(MainScheduler.instance)
  23.     .subscribe { print($0) }
  25. // URLHTTPResponse + Validation + String
  26. _ = manager.rx.request(.get, stringURL)
  27.     .flatMap {
  28.         $0
  29.             .validate(statusCode: 200 ..< 300)
  30.             .validate(contentType: ["text/json"])
  31.             .rx.string()
  32.     }
  33.     .observeOn(MainScheduler.instance)
  34.     .subscribe { print($0) }

你可以点击 RxAlamofire 来了解更多信息。

RxRealm

Realm 是一个十分前卫的跨平台数据库，他想要替换 Core Data 和 SQLite。RxRealm 是用 RxSwift 封装的 Realm。它使我们可以用 Rx 的方式监听数据变化，或者将数据写入数据库。

监听数据：

  1. let realm = try! Realm()
  2. let laps = realm.objects(Lap.self)
  4. Observable.collection(from: laps)
  5.   .map {
  6.     laps in "\(laps.count) laps"
  7.   }
  8.   .subscribe(onNext: { text  in
  9.     print(text)
  10.   })

添加数据：

  1. let realm = try! Realm()
  2. let messages = [Message("hello"), Message("world")]
  4. Observable.from(messages)
  5.   .subscribe(realm.rx.add())

删除数据：

  1. let realm = try! Realm()
  2. let messages = realm.objects(Message.self)
  4. Observable.from(messages)
  5.   .subscribe(realm.rx.delete())

你可以点击 RxRealm 来了解更多信息。

RxSwift 生态系统 - 图5 ReactiveX 生态系统

我们之前提到过 RxSwift 是 Rx 的 Swift 版本。而 ReactiveX（简写: Rx）是一个跨平台框架。它不仅可以用来写 iOS ，你还可以用它来写 Android，Web 前端和后台。并且每个平台都和 RxSwift 一样有一套 Rx 生态系统。Rx 支持多种编程语言，如：Swift，Java，JS，C#，Scala，Kotlin，Go 等。只要你掌握了其中一门语言，你很容易就能够熟悉其他的语言。

Android

RxJava 是 Android 平台上非常流行的响应式编程框架，它也是 Rx 的 Java 版本。

我们还是用输入验证来做演示：

iOS（RxSwift） 版：

  1. ...
  2. let usernameValid = usernameOutlet.rx.text.orEmpty
  3.     .map { $0.characters.count >= minimalUsernameLength }
  4.     .share(replay: 1)
  6. let passwordValid = passwordOutlet.rx.text.orEmpty
  7.     .map { $0.characters.count >= minimalPasswordLength }
  8.     .share(replay: 1)
  10. let everythingValid = Observable
  11.     .combineLatest(usernameValid, passwordValid) { $0 && $1 }
  12.     .share(replay: 1)
  14. usernameValid
  15.     .bind(to: passwordOutlet.rx.isEnabled)
  16.     .disposed(by: disposeBag)
  18. usernameValid
  19.     .bind(to: usernameValidOutlet.rx.isHidden)
  20.     .disposed(by: disposeBag)
  22. passwordValid
  23.     .bind(to: passwordValidOutlet.rx.isHidden)
  24.     .disposed(by: disposeBag)
  26. everythingValid
  27.     .bind(to: doSomethingOutlet.rx.isEnabled)
  28.     .disposed(by: disposeBag)
  29. ...

Android（RxJava） 版：

  1. ...
  2. final Observable<Boolean> usernameValid = RxTextView.textChanges(usernameEditText)
  3.         .map(text -> text.length() >= minimalUsernameLength)
  4.         .compose(Rx.shareReplay(1));
  6. final Observable<Boolean> passwordValid = RxTextView.textChanges(usernameEditText)
  7.         .map(text -> text.length() >= minimalPasswordLength)
  8.         .compose(Rx.shareReplay(1));
  10. final Observable<Boolean> everythingValid = Observable
  11.         .combineLatest(usernameValid, passwordValid, (isUsernameValid, isPasswordValid) -> isUsernameValid && isPasswordValid)
  12.         .compose(Rx.shareReplay(1));
  14. disposables.add(usernameValid
  15.         .subscribe(RxView.enabled(passwordEditText)));
  17. disposables.add(usernameValid
  18.         .subscribe(RxView.visibility(usernameValidTextView)));
  20. disposables.add(passwordValid
  21.         .subscribe(RxView.visibility(passwordValidTextView)));
  23. disposables.add(everythingValid
  24.         .subscribe(RxView.enabled(doSomethingButton)));
  25. ...

这两段代码的逻辑是一样的，一个是 iOS（RxSwift） 版本，另一个是 Android（RxJava） 版本。仔细对比以后，你会发现它们的书写方式都是差不多的。

这样一来，你就可以用同一套逻辑来写跨平台应用，而且这个应用是纯原生的。这不仅节省了开发时间，而且还提升了 App 的质量。

Web 前端

RxJS 是 Web 前端 平台上非常流行的响应式编程框架，它也是 Rx 的 JS 版本。而且主流的前端框架都提供了 Rx 支持，如：jQuery，RxJS-DOM，AngularJS，RxEmber等。

下面这个例子是用 RxJS 写的，它和 GitHub 搜索 十分相似，只不过他搜索的是维基百科：

  1. var $input = $('#input'),
  2.     $results = $('#results');
  4. Rx.Observable.fromEvent($input, 'keyup')
  5.     .map(e => e.target.value)
  6.     .filter(text => text.length > 2)
  7.     .throttle(500 /* ms */);
  8.     .distinctUntilChanged();
  9.     .flatMapLatest(searchWikipedia);
  10.     .subscribe(data => {
  11.         var res = data[1];
  12.         $results.empty();
  13.         $.each(res, (_, value) => $('<li>' + value + '</li>').appendTo($results));
  14.     }, error => {
  15.         $results.empty();
  16.         $('<li>Error: ' + error + '</li>').appendTo($results);
  17.     });

当用户输入一个稳定的关键字后，向维基百科请求搜索结果，然后显示出来。

即便你没有学过 Web 前端开发，但是只要你熟悉 Rx ，以上代码你也能够看懂。

总结

由于 Rx 支持多种后台语言，如：Java，JS，Go。所以你也可以用它来写后台。

如果你已经能够熟练使用 RxSwift ，那么你就已经具有某种“天赋”，这种“天赋”可以帮助你快速上手其他平台。你只需要学习一些和平台相关的知识，就可以写出交互相当复杂的应用程序。因为你的 Rx 技巧是可以跨平台复用的。

另外，你的学习效率也会更高，如果你在 RxSwift 中学到了某些技巧，那么这个技巧通常也可以被应用到 Android 或者其他的平台。如果你在 RxJava 中学到了某些技巧，那么这个技巧通常也可以被应用到 iOS 平台。因此，你的学习资源也就不再局限于 RxSwift，你还可以浏览其他平台上关于 Rx 的教程。

下一章将提供一些关于 RxSwift 的学习资源。