Kotlin FestのLTのネタです。(3分でどこまで話せるか謎です。)

きっかけ

RxJavaとCoroutinesについてJakeさんが以下のように言っていて、確かにsuspendメソッドのほうがわかりやすく書けると自分も感じています。

また既存のアプリの実装を思い浮かべたときにほとんどのRxJavaを使っているところがSingleまたはCompletableなどだったので、置き換えたほうが良さそうでは？と思いました。
個人的にはRxJavaのObservableで使っているところは、Coroutinesではそこまでスマートにはかけなさそうで、そのままでもいいかなという感じです。

そこですごく簡単なアプリで、移行するサンプルアプリを書いてみました。

例となるRxJavaのアプリ

簡単な例で、ViewModelがRxJavaを使ってApiクラスから情報を取得して、LiveDataに流すだけです。

class ViewModel(
    private val api: Api = Api(),
    private val scheduler: Scheduler = Schedulers.io()
) {
  private val mutablePersons = MutableLiveData<List<Person>>()
  val persons: LiveData<List<Person>> = mutablePersons

  fun onCreate() {
    api.fetchPersons()
        .subscribeOn(scheduler)
        .subscribe(mutablePersons::postValue)
  }
}

置き換えする時の問題

大きなアプリで、置き換えていくときApiのクラスの実装を変えてしまうと既存のすべての実装を置き換える必要がありそうです

kotlinx-coroutines-rx2

そこで、kotlinx-coroutines-rx2を使うと、以下のように変換できます。

import kotlinx.coroutines.experimental.rx2.await

class ViewModel(
    private val api: Api = Api(),
    private val coroutineContext: CoroutineContext = CommonPool
) {
  private val mutablePersons = MutableLiveData<List<Person>>()
  val persons: LiveData<List<Person>> = mutablePersons

  fun onCreate() {
    launch(coroutineContext) { // Kotlin Coroutines起動
      // ** ここでRxJavaのSingleを中断関数に変換 **
      val persons = api.fetchPersons().await()
      mutablePersons.postValue(persons)
    }
  }
}

kotlinx-coroutines-rx2を使うことで、逆にsuspendメソッドからRxJavaのsingleにも置き換えができます。

サンプルアプリを用意

置き換えていけるのか検証の意味も込めて、以下のようにサンプルアプリを用意しました。
https://github.com/takahirom/rxjava-2-kotlion-coroutines

	Source code	test
RxJavaのアプリ	Source code	Test
CoroutinesからRxJavaのSingleを使う例	Source code	Test
RxJavaからCoroutinesのsuspend functionを使う例	Source code	Test
Coroutinesを使う例	Source code	Test

テスト、エラーハンドリング、ライフサイクルを考慮した例

実際に書いていくときはいくつかのポイントを意識する必要があるのでそれを含んだサンプルも用意しています。
https://github.com/takahirom/rxjava-2-kotlion-coroutines/tree/master/5_coroutines_advanced/src

ポイント1: CoroutineContextを渡すことで、テスト時に切り替えられるようにして、テスト可能にする。
ポイント2: Jobを親として渡して、それをViewModel#onClearedでcancelすることで、使われない無駄な処理をさせないことができる。(これはなくても問題なく動作し、オプションと言えそう)
ポイント3: RxJavaのonErrorで処理をしていたのであれば、同じように、launch内でクラッシュしたときにハンドリングしてあげる必要がある。

他にもViewModelが外からいじれないようにフィールドを分けたり、SingleLiveDataを使って、画面回転時に知らせないようにするなど、工夫をしていますが、Coroutinesとは関係ないので、省略します。

class PersonsViewModel(
    private val api: Api = Api(),
    coroutineContext: CoroutineContext = CommonPool // ポイント1
) : ViewModel() {
  private val compositeJob = Job() // ポイント2
  private val mutablePersons = MutableLiveData<List<Person>>()
  val persons: LiveData<List<Person>> = mutablePersons

  private val singleError: SingleLiveData<Exception> = SingleLiveData()
  val errors: LiveData<Exception> = singleError

  init {
    launch(coroutineContext, parent = compositeJob) {  // ポイント2
      try { // ポイント3
        val persons = api.fetchPersons()
        mutablePersons.postValue(persons)
      } catch (e: Exception) {
        singleError.postValue(e)
      }
    }
  }

  override fun onCleared() {
    compositeJob.cancel()
  }
}

まとめ

まだまだ知見やベストプラクティスを探っている状態ですが、見つけていきたいです。
こうしたらいいなどのコメントをTwitterなどでもいいのでお待ちしています

RxJavaを使っている既存アプリに Kotlin Coroutinesを導入しよう