RxSwiftとは

コードが新しいデータに反応、順次的に分離された方式で処理される、非同期プログラム開発が簡素化できる、データの変化に対応しやすい。
observable asynchronous functional via schedulers

RxSwiftの基礎

Rxの3つの構成要素についてみてみる
Observables、Operators、Schedulers

1.Observables

Observable クラスはRxの基盤
Tタイプのデータを渡す、イベントを非同期に生成
- 他のクラスでemit(放出？)する値を購読できるようにする
ObservableTypeのProtocol(Observable)はシンプルで、以下の３つのイベントのみemitし、observersはこの３つのみ受信できる
- next：最新/次のデータを渡すイベント
- completed：成功的にイベントを終了させるイベント。追加イベント生成しない
- error：Observableがエラー発生。追加イベント生成しない

Finite Observable Sequences (有限の観測可能なシーケンス)

例えば、ファイルをダウンロードするコードをイメージ
流れは
1. ファイルのダウンロードが始まって、データを監視する
2. 続けてファイルをダウンロードする
3. (エラーの場合)ネットワークが切れたらエラーになって停止する
4. (成功した場合)問題なくダウンロードが成功する

API.download(file: "https://www...")
    .subscribe(onNext: { data in
        ... append data to temporary file
    },
    onError: { error in 
        ... display error to user
    },
    onCompleted: {
        ... use downloaded file
    })

API.downloadはダウンロードするデータObservable<Data>インスタンスをreturn
onNextクロージャでnextイベントを受け取ることができる。
onErrorクロージャではerrorイベントが受け取れる。
最終的にはonCompletedクロージャでcompletedイベントを受け取る

Infinite Observable Sequences(無限の観測可能なシーケンス)

ダウンロードのように自然に終了するものとは異なって、無限なsequenceがある。例えばUIイベントなどは無限に観測できる。
例えば、デバイスの横/縦モードに反応するコードをイメージ
流れは
1. UIDeviceOrientationDidChange observerを追加
2. 方向転換が管理できるcallback methodが必要
3. UIDeviceの現在の方向を確認して、画面に表示する
4. 方向転換ができるデバイスが存在する以上、自然に終了することはない
5. 無限なsequenceなので一応初期値が必要

UIDevice.rx.orientation
    .subscribe(onNext: { current in
        switch current {
            case .landscape:
                ... re-arrange UI for landscape
            case .portrait:
                ... re-arrange UI for portrait
        }
    })

ここでは、onErroronCompletedは発生しないはずなので、記述も不要

2. Operators

ObservableTypeとObservableクラスはより複雑な論理を実現するためにたくさんのメソッドが含まれている。それらをOperatorを呼ぶ
Operatorは非同期入力を受けて出力のみ生成するだけで、複数のOperatorを併せて使うことができる
- Observableに、より入ってきたのを処理して放出？する役割

コードを見た方が分かりやすいかも

UIDevice.rx.orientation
  .filter { value in
    return value != .landscape
  }
  .map { _ in
    return "Only Portrait"
  }
  .subscribe(onNext: { string in
    showAlert(string)
  })

上記でみると分かるように filterは.landscapeではないものだけ、return
.portraitの場合はmapに入るはずで、mapではStringに変換してreturn
最後にsubscribeでは結果としてstringをshowAlertメソッドで表示している

このように複数のOperatorを使って、いろんなことができる。

3.Schedulers

SchedulersはRxではdispatch queueと同じだが、もっと使いやすくて強力
RxSwiftではいろんなスクジューラーが既に定義されている。99％の状況で使えるので、開発者が自分だけのスケジューラーを生成することはない

RxCocoa

RxSwiftは一般的なRx APIで、Cocoaとか特定のUIKitクラスについて何の情報も持たない。RxCocoaはRxSwiftと一緒に使われながら、UIKitやCocoaフレームワーク基盤開発をサポートする全てのクラスを持っているらしい。

[RxSwift] RxSwiftとは