RxAndroid - AndroidSchedulers

這實際上是你在 Android 上開始使用 RxJava 所需的唯一內容。

在你的 gradle 依賴項中包含 RxJava 和 RxAndroid ：

 // use the last version
compile 'io.reactivex.rxjava2:rxjava:2.1.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

RxAndroid 是 RxJava 的主要補充，是 Android 主執行緒或 UI 執行緒的排程程式。

在你的程式碼中：

Observable.just("one", "two", "three", "four", "five")
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
            data -> doStuffOnMainThread(),
            error -> handleErrorOnMainThread()
        )

或者，你可以為自定義 Looper 建立計劃程式：

Looper backgroundLooper = // ...
Observable.just("one", "two", "three", "four", "five")
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.from(backgroundLooper))
        .subscribe(
            data -> doStuffOnMainThread(),
            error -> handleErrorOnMainThread()
        )

對於大多數其他內容，你可以參考標準的 RxJava 文件。