RxKotlin

Tweet

生産者を意味するのがFlowable。
購読者を意味するのがsubscribe。

Subscriptionの処理がSubscriberの外部から呼ばれない前提で行っているためできる実装。
外部から購読解除を行うような仕組みを提供している場合は、Subscriptionが非同期で呼ばれても問題ないようにする必要がある。

ProcessorはReactiveStreamsにだけあるインターフェース。

Stream対応なしの場合、バックプレッシャーの機能がなく、データ数のリクエストは行わない。
また、Subscriptionは使わず、Disposableという購読解除のメソッドを持つインターフェースを使います。

オペレーター

RxJavaでは生産者(observer)が通知したデータが消費者(Subscriber)に届くまでに、不要なデータを破棄したり、データを消費者で使いやすいように変換したりと通知のデータを操作することがある。
この際に使用するメソッドはObservableのメソッドから新たなObservableヲ返す作りになっており、このメソッドをつなげていくことで、最終的なデータを通知するObserbableを生成する。
ようするにメソッドチェーン。

非同期処理

RxJavaはデータを通知する側の処理ハンチとデータを受け取る側の処理範囲を分断できる設計になっているっために、それぞれの処理を別スレッドで行えるようになっている。
Rxjavaでは、開発者が直接スレッドを管理しなくても良いように、書く処理の用途に合ったスレッド管理を行うSchedulerを用意している。

Completable

Completableはデータを通知することなく完了を通知するか、もしくはエラーを通知するクラス。
DBのレコードのインサートや更新などに使う。

Single

emitterのonSuccessを呼ぶと一回だけObserver(Subscriber)のonSuccessが呼ばれます。(itemが一個だけemitされます。)複数回onSuccessを呼んでも一回だけしか呼ばれません。
onCompleteメソッドはないです。
つまり、onSuccessは引数が必要なので、何もアイテムを流さずにonCompleteメソッドを呼んだりできません。

fromCallable

fromCallbleメソッドを使って呼び出されるとシステム時間を取得するCallableからデータを取得し、それを通知する。