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 文档。