它提供了一個可以在給定的Android Handler 上調(diào)度 Observable 的調(diào)度器 Scheduler，特別是在UI主線程上。
它提供了一些操作符，讓你可以更容易的處理 Fragment 和 Activity 的生命周期方法。
它提供了很多Android消息和通知組件的包裝類，用于與Rx的調(diào)用鏈搭配使用。
針對常見的Android用例和重要的UI，它提供了可復(fù)用的、自包含的響應(yīng)式組件。（即將到來）

Binaries

你可以在 http://search.maven.org 找到用于Maven, Ivy, Gradle和其它構(gòu)建系統(tǒng)的二進制文件和依賴信息。

Maven 示例：

<dependency>
    <groupId>io.reactivex</groupId>
    <artifactId>rxandroid</artifactId>
    <version>0.23.0</version>
</dependency>

Ivy 示例：

<dependency org="io.reactivex" name="rxandroid" rev="0.23.0" />

當前支持的最低API版本(minSdkVersion)是 10 (Android 2.3/Gingerbread)

示例

在UI線程觀察(Observing)

在Android上，通常處理異步任務(wù)時你會在主線程上等待(observing)處理結(jié)果，一般情況下你使用 AsyncTask 達到這個目的。使用RxJava，你會使用 observeOn 操作符聲明你要在主線程等待 Observable 的結(jié)果：

public class ReactiveFragment extends Fragment {

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    Observable.from("one", "two", "three", "four", "five")
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(/* an Observer */);
}

這個例子中，Observable在一個新的線程執(zhí)行，結(jié)果通過 onNext 在主線程發(fā)射。

在任意線程觀察(Observing)

前面的例子是一個普遍概念的特殊版本：Android使用一個叫 Handler 的類綁定異步通信到消息循環(huán)。為了在任意線程 觀察 一個Observable，需要創(chuàng)建一個與那個類關(guān)聯(lián)的 Handler，然后使用 AndroidSchedulers.handlerThread 調(diào)度器：

new Thread(new Runnable() {
    @Override
    public void run() {
        final Handler handler = new Handler(); // bound to this thread
        Observable.from("one", "two", "three", "four", "five")
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.handlerThread(handler))
                .subscribe(/* an Observer */)

        // perform work, ...
    }
}, "custom-thread-1").start();

這個例子中，Observable在一個新的線程執(zhí)行，結(jié)果通過 onNext 在 custom-thread-1 線程上發(fā)射。（這個例子不太自然，因為你可以調(diào)用observeOn(Schedulers.currentThread())，但是它說清楚了這個想法。）

Fragment和Activity生命周期

在Android上，要在異步操作中訪問框架中的對象有些棘手，那是因為Andoid系統(tǒng)可以決定銷毀(destroy)一個 Activity，例如，當一個后臺線程還在運行的時候，如果這個線程嘗試訪問一個已經(jīng)死掉的Activity中的View對象，會導(dǎo)致異常退出(Crash)。（這也會導(dǎo)致內(nèi)存泄露，因為 Activity 已經(jīng)不可見了，你的后臺線程還持有它的引用。）

這仍然是在Android上使用RxJava需要關(guān)注的一個問題，但是通過使用 Subscription和其它Observable操作符，你可以優(yōu)雅地解決這個問題。通常來說，當你在Activity中訂閱一個Observable的結(jié)果時（無論是直接的還是通過一個內(nèi)部類），你必須在 onDestroy 里取消訂閱，就像下面例子里展示的那樣：

// MyActivity
private Subscription subscription;

protected void onCreate(Bundle savedInstanceState) {
    this.subscription = observable.subscribe(this);
}

...

protected void onDestroy() {
    this.subscription.unsubscribe();
    super.onDestroy();
}

這樣確保所有指向訂閱者(這個Activity)的引用盡快釋放，不會再有通知通過 onNext 發(fā)射給這個訂閱者。

有一個問題，如果由于屏幕方向的變化導(dǎo)致這個 Activity 被銷毀，在 onCreate 中這個Observable會再次啟動。你可以使用 cache 或 replay 操作符阻止它發(fā)生，這些操作符保證Observable在 Activity 的生命周期內(nèi)存在（你可以在一個全局的緩存中保存它，比如放在Fragment中。）你可以使用任何操作符，只要能保證：當訂閱者訂閱一個已經(jīng)在運行的Observable時，在它與Activity 解除關(guān)聯(lián)的這段時間里發(fā)射的數(shù)據(jù)都會被回放，并且來自這個Observable的任何離線通知都會正常分發(fā)。

參考資料

How the New York Times is building its Android app with Groovy/RxJava by Mohit Pandey
Functional Reactive Programming on Android With RxJava and Conquering concurrency - bringing the Reactive Extensions to the Android platform by Matthias K?ppler
Learning RxJava for Android by example by Kaushik Gopal
Top 7 Tips for RxJava on Android and Rx Architectures in Android by Timo Tuominen
FRP on Android by Yaroslav Heriatovych
Rx for .NET and RxJava for Android by Olli Salonen
RxJava in Xtend for Android by Andre Medeiros
RxJava and Xtend by Stefan Oehme
Grokking RxJava, Part 1: The Basics, Part 2: Operator, Operator, Part 3: Reactive with Benefits, Part 4: Reactive Android - published in Sep/Oct 2014 by Daniel Lew

上一篇：Retry下一篇：SkipLast