Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南

前言

Rxjava由于其基于事件流的鏈?zhǔn)秸{(diào)用、邏輯簡潔 & 使用簡單的特點蜓谋，深受各大 Android開發(fā)者的歡迎娜亿。

如果還不了解RxJava，請看文章：Android：這是一篇清晰 & 易懂的Rxjava 入門教程

今天廓块，Carson將為初學(xué)者帶來 RxJava的基本使用厢绝，希望大家會喜歡。

Carson帶你學(xué)RxJava系列文章带猴，包括 原理昔汉、操作符、應(yīng)用場景拴清、背壓等等靶病，請關(guān)注看文章：Android：這是一份全面 & 詳細(xì)的RxJava學(xué)習(xí)指南

1. RxJava簡介

此處簡單介紹RxJava

示意圖

若還不了解RxJava，請看文章：Android：這是一篇清晰 & 易懂的Rxjava 入門教程

2. 基本使用

本文只關(guān)注 RxJava的基本使用贷掖，更深入的RxJava使用請繼續(xù)關(guān)注Carson_Ho的RxJava系列
Rxjava的使用方式有兩種：
1. 分步驟實現(xiàn)：該方法主要為了深入說明Rxjava的原理 & 使用嫡秕，主要用于演示說明
2. 基于事件流的鏈?zhǔn)秸{(diào)用：主要用于實際使用

2.1 方式1：分步驟實現(xiàn)

2.1.1 使用步驟

示意圖

2.1.2 步驟詳解

步驟1：創(chuàng)建被觀察者（`Observable` ）& 生產(chǎn)事件

即顧客入飯店 - 坐下餐桌 - 點菜
具體實現(xiàn)

        // 1. 創(chuàng)建被觀察者 Observable 對象
        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {
          // create() 是 RxJava 最基本的創(chuàng)造事件序列的方法
          // 此處傳入了一個 OnSubscribe 對象參數(shù)
          // 當(dāng) Observable 被訂閱時，OnSubscribe 的 call() 方法會自動被調(diào)用苹威，即事件序列就會依照設(shè)定依次被觸發(fā)
          // 即觀察者會依次調(diào)用對應(yīng)事件的復(fù)寫方法從而響應(yīng)事件
          // 從而實現(xiàn)被觀察者調(diào)用了觀察者的回調(diào)方法 & 由被觀察者向觀察者的事件傳遞昆咽，即觀察者模式

        // 2. 在復(fù)寫的subscribe（）里定義需要發(fā)送的事件
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                // 通過 ObservableEmitter類對象產(chǎn)生事件并通知觀察者
                // ObservableEmitter類介紹
                    // a. 定義：事件發(fā)射器
                    // b. 作用：定義需要發(fā)送的事件 & 向觀察者發(fā)送事件
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onComplete();
            }
        });

<--擴展：RxJava 提供了其他方法用于 創(chuàng)建被觀察者對象Observable -->
// 方法1：just(T...)：直接將傳入的參數(shù)依次發(fā)送出來
  Observable observable = Observable.just("A", "B", "C");
  // 將會依次調(diào)用：
  // onNext("A");
  // onNext("B");
  // onNext("C");
  // onCompleted();

// 方法2：from(T[]) / from(Iterable<? extends T>) : 將傳入的數(shù)組 / Iterable 拆分成具體對象后，依次發(fā)送出來
  String[] words = {"A", "B", "C"};
  Observable observable = Observable.from(words);
  // 將會依次調(diào)用：
  // onNext("A");
  // onNext("B");
  // onNext("C");
  // onCompleted();

步驟2：創(chuàng)建觀察者（`Observer` ）并定義響應(yīng)事件的行為

即開廚房 - 確定對應(yīng)菜式
發(fā)生的事件類型包括：Next事件、Complete事件 & Error事件掷酗。具體如下：

示意圖

具體實現(xiàn)


<--方式1：采用Observer 接口 -->
        // 1. 創(chuàng)建觀察者 （Observer ）對象
        Observer<Integer> observer = new Observer<Integer>() {
        // 2. 創(chuàng)建對象時通過對應(yīng)復(fù)寫對應(yīng)事件方法 從而 響應(yīng)對應(yīng)事件

            // 觀察者接收事件前调违，默認(rèn)最先調(diào)用復(fù)寫 onSubscribe（）
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }
            
            // 當(dāng)被觀察者生產(chǎn)Next事件 & 觀察者接收到時，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件作出響應(yīng)" + value);
            }

            // 當(dāng)被觀察者生產(chǎn)Error事件& 觀察者接收到時泻轰，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }
          
            // 當(dāng)被觀察者生產(chǎn)Complete事件& 觀察者接收到時技肩，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        };

<--方式2：采用Subscriber 抽象類 -->
// 說明：Subscriber類 = RxJava 內(nèi)置的一個實現(xiàn)了 Observer 的抽象類，對 Observer 接口進(jìn)行了擴展

// 1. 創(chuàng)建觀察者 （Observer ）對象
Subscriber<String> subscriber = new Subscriber<Integer>() {

// 2. 創(chuàng)建對象時通過對應(yīng)復(fù)寫對應(yīng)事件方法 從而 響應(yīng)對應(yīng)事件
            // 觀察者接收事件前浮声，默認(rèn)最先調(diào)用復(fù)寫 onSubscribe（）
            @Override
            public void onSubscribe(Subscription s) {
                Log.d(TAG, "開始采用subscribe連接");
            }

            // 當(dāng)被觀察者生產(chǎn)Next事件 & 觀察者接收到時虚婿，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件作出響應(yīng)" + value);
            }

            // 當(dāng)被觀察者生產(chǎn)Error事件& 觀察者接收到時，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            // 當(dāng)被觀察者生產(chǎn)Complete事件& 觀察者接收到時泳挥，會調(diào)用該復(fù)寫方法 進(jìn)行響應(yīng)
            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        };


<--特別注意：2種方法的區(qū)別然痊，即Subscriber 抽象類與Observer 接口的區(qū)別 -->
// 相同點：二者基本使用方式完全一致（實質(zhì)上，在RxJava的 subscribe 過程中屉符，Observer總是會先被轉(zhuǎn)換成Subscriber再使用）
// 不同點：Subscriber抽象類對 Observer 接口進(jìn)行了擴展剧浸，新增了兩個方法：
    // 1. onStart()：在還未響應(yīng)事件前調(diào)用，用于做一些初始化工作
    // 2. unsubscribe()：用于取消訂閱矗钟。在該方法被調(diào)用后唆香，觀察者將不再接收 & 響應(yīng)事件
    // 調(diào)用該方法前，先使用 isUnsubscribed() 判斷狀態(tài)吨艇，確定被觀察者Observable是否還持有觀察者Subscriber的引用躬它，如果引用不能及時釋放，就會出現(xiàn)內(nèi)存泄露

步驟3：通過訂閱（`Subscribe`）連接觀察者和被觀察者

即顧客找到服務(wù)員 - 點菜 - 服務(wù)員下單到廚房 - 廚房烹調(diào)
具體實現(xiàn)

observable.subscribe(observer);
 // 或者 observable.subscribe(subscriber)东涡；

擴展說明

<-- Observable.subscribe(Subscriber) 的內(nèi)部實現(xiàn) -->

public Subscription subscribe(Subscriber subscriber) {
    subscriber.onStart();
    // 步驟1中 觀察者  subscriber抽象類復(fù)寫的方法虑凛，用于初始化工作
    onSubscribe.call(subscriber);
    // 通過該調(diào)用，從而回調(diào)觀察者中的對應(yīng)方法從而響應(yīng)被觀察者生產(chǎn)的事件
    // 從而實現(xiàn)被觀察者調(diào)用了觀察者的回調(diào)方法 & 由被觀察者向觀察者的事件傳遞软啼，即觀察者模式
    // 同時也看出：Observable只是生產(chǎn)事件，真正的發(fā)送事件是在它被訂閱的時候延柠，即當(dāng) subscribe() 方法執(zhí)行時
}

2.2 方式2：優(yōu)雅的實現(xiàn)方法 - 基于事件流的鏈?zhǔn)秸{(diào)用

上述的實現(xiàn)方式是為了說明Rxjava的原理 & 使用
在實際應(yīng)用中祸挪，會將上述步驟&代碼連在一起，從而更加簡潔贞间、更加優(yōu)雅贿条，即所謂的 RxJava基于事件流的鏈?zhǔn)秸{(diào)用

// RxJava的鏈?zhǔn)讲僮?        Observable.create(new ObservableOnSubscribe<Integer>() {
        // 1. 創(chuàng)建被觀察者 & 生產(chǎn)事件
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onComplete();
            }
        }).subscribe(new Observer<Integer>() {
            // 2. 通過通過訂閱（subscribe）連接觀察者和被觀察者
            // 3. 創(chuàng)建觀察者 & 定義響應(yīng)事件的行為
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }
            // 默認(rèn)最先調(diào)用復(fù)寫的 onSubscribe（）

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件"+ value +"作出響應(yīng)"  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }

        });
    }
}

注：整體方法調(diào)用順序：觀察者.onSubscribe（）> 被觀察者.subscribe（）> 觀察者.onNext（）>觀察者.onComplete()

這種 基于事件流的鏈?zhǔn)秸{(diào)用，使得RxJava：

邏輯簡潔
實現(xiàn)優(yōu)雅
使用簡單

更重要的是增热，隨著程序邏輯的復(fù)雜性提高整以，它依然能夠保持簡潔 & 優(yōu)雅。所以峻仇，一般建議使用這種基于事件流的鏈?zhǔn)秸{(diào)用方式實現(xiàn)RxJava公黑。

特別注意

RxJava 2.x 提供了多個函數(shù)式接口，用于實現(xiàn)簡便式的觀察者模式。具體如下：

示意圖

以 Consumer為例：實現(xiàn)簡便式的觀察者模式

Observable.just("hello").subscribe(new Consumer<String>() {
            // 每次接收到Observable的事件都會調(diào)用Consumer.accept（）
            @Override
            public void accept(String s) throws Exception {
                System.out.println(s);
            }
        });

3. 實例講解

我將用一個實際工程實例來演示 Rxjava的使用

3.1 方式1：分步驟實現(xiàn)

步驟1：加入依賴

    compile 'io.reactivex.rxjava2:rxjava:2.0.1'
    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

步驟2：直接在MainActivity.java中實現(xiàn)下述步驟

創(chuàng)建被觀察者 （Observable ）& 生產(chǎn)事件
創(chuàng)建觀察者 （Observer ）并定義響應(yīng)事件的行為
通過訂閱（Subscribe）連接觀察者和被觀察者

public class MainActivity extends AppCompatActivity {

    private static final String TAG = "Rxjava";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);



// 步驟1：創(chuàng)建被觀察者 Observable & 生產(chǎn)事件
// 即 顧客入飯店 - 坐下餐桌 - 點菜
        
        //  1. 創(chuàng)建被觀察者 Observable 對象
        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {
            // 2. 在復(fù)寫的subscribe（）里定義需要發(fā)送的事件
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                // 通過 ObservableEmitter類對象產(chǎn)生事件并通知觀察者
                // ObservableEmitter類介紹
                    // a. 定義：事件發(fā)射器
                    // b. 作用：定義需要發(fā)送的事件 & 向觀察者發(fā)送事件
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onComplete();
            }
        });

// 步驟2：創(chuàng)建觀察者 Observer 并 定義響應(yīng)事件行為
// 即 開廚房 - 確定對應(yīng)菜式
        
        Observer<Integer> observer = new Observer<Integer>() {
            // 通過復(fù)寫對應(yīng)方法來 響應(yīng) 被觀察者
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }
            // 默認(rèn)最先調(diào)用復(fù)寫的 onSubscribe（）

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件"+ value +"作出響應(yīng)"  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        };

        
        // 步驟3：通過訂閱（subscribe）連接觀察者和被觀察者
        // 即 顧客找到服務(wù)員 - 點菜 - 服務(wù)員下單到廚房 - 廚房烹調(diào)
        observable.subscribe(observer);

測試結(jié)果

示意圖

3.2 方式2：基于事件流的鏈?zhǔn)秸{(diào)用方式

public class MainActivity extends AppCompatActivity {

    private static final String TAG = "Rxjava";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

// RxJava的流式操作
        Observable.create(new ObservableOnSubscribe<Integer>() {
        // 1. 創(chuàng)建被觀察者 & 生產(chǎn)事件
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onComplete();
            }
        }).subscribe(new Observer<Integer>() {
            // 2. 通過通過訂閱（subscribe）連接觀察者和被觀察者
            // 3. 創(chuàng)建觀察者 & 定義響應(yīng)事件的行為
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }
            // 默認(rèn)最先調(diào)用復(fù)寫的 onSubscribe（）

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件"+ value +"作出響應(yīng)"  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }

        });
    }
}

測試效果
實現(xiàn)效果同上

示意圖
Demo 下載地址
Carson_Ho的Github地址 = RxJava2系列：基礎(chǔ)使用

喜歡的麻煩點個star凡蚜！

4. 額外說明

4.1 觀察者 Observer的subscribe()具備多個重載的方法

    public final Disposable subscribe() {}
    // 表示觀察者不對被觀察者發(fā)送的事件作出任何響應(yīng)（但被觀察者還是可以繼續(xù)發(fā)送事件）

    public final Disposable subscribe(Consumer<? super T> onNext) {}
    // 表示觀察者只對被觀察者發(fā)送的Next事件作出響應(yīng)
    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} 
    // 表示觀察者只對被觀察者發(fā)送的Next事件 & Error事件作出響應(yīng)

    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}
    // 表示觀察者只對被觀察者發(fā)送的Next事件人断、Error事件 & Complete事件作出響應(yīng)

    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}
    // 表示觀察者只對被觀察者發(fā)送的Next事件、Error事件 朝蜘、Complete事件 & onSubscribe事件作出響應(yīng)

    public final void subscribe(Observer<? super T> observer) {}
    // 表示觀察者對被觀察者發(fā)送的任何事件都作出響應(yīng)

4.2 可采用 Disposable.dispose() 切斷觀察者與被觀察者之間的連接

即觀察者無法繼續(xù) 接收被觀察者的事件恶迈，但被觀察者還是可以繼續(xù)發(fā)送事件
具體使用


// 主要在觀察者 Observer中 實現(xiàn)
        Observer<Integer> observer = new Observer<Integer>() {
            // 1. 定義Disposable類變量
            private Disposable mDisposable;

            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
                // 2. 對Disposable類變量賦值
                mDisposable = d;
            }

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "對Next事件"+ value +"作出響應(yīng)"  );
                if (value == 2) {
                    // 設(shè)置在接收到第二個事件后切斷觀察者和被觀察者的連接
                    mDisposable.dispose();
                    Log.d(TAG, "已經(jīng)切斷了連接：" + mDisposable.isDisposed());
                }
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        };

效果圖

示意圖

至此，關(guān)于RxJava的基礎(chǔ)使用講解完畢谱醇。

5. 總結(jié)

本文主要講解 Rxjava 的基礎(chǔ)使用暇仲，更多實例應(yīng)用請看文章：Android RxJava實際應(yīng)用教學(xué)：你該什么時候使用RxJava？
Carson帶你學(xué)RxJava系列文章：

入門
Carson帶你學(xué)Android：這是一篇清晰易懂的Rxjava入門教程
 Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南
 Carson帶你學(xué)Android：RxJava2.0到底更新了什么副渴？
原理
Carson帶你學(xué)Android：圖文解析RxJava原理
 Carson帶你學(xué)Android：手把手帶你源碼分析RxJava
使用教程：操作符
Carson帶你學(xué)Android：RxJava操作符教程
 Carson帶你學(xué)Android：RxJava創(chuàng)建操作符
 Carson帶你學(xué)Android：RxJava功能性操作符
 Carson帶你學(xué)Android：RxJava過濾操作符
 Carson帶你學(xué)Android：RxJava組合/合并操作符
 Carson帶你學(xué)Android：RxJava變換操作符
 Carson帶你學(xué)Android：RxJava條件/布爾操作符
實戰(zhàn)
Carson帶你學(xué)Android：什么時候應(yīng)該使用Rxjava奈附？(開發(fā)場景匯總)
Carson帶你學(xué)Android：RxJava線程控制(含實例講解)
Carson帶你學(xué)Android：圖文詳解RxJava背壓策略
 Carson帶你學(xué)Android：RxJava、Retrofit聯(lián)合使用匯總(含實例教程)
Carson帶你學(xué)Android：優(yōu)雅實現(xiàn)網(wǎng)絡(luò)請求嵌套回調(diào)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(有條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(無條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求出錯重連(結(jié)合Retrofit)
Carson帶你學(xué)Android：合并數(shù)據(jù)源
 Carson帶你學(xué)Android：聯(lián)想搜索優(yōu)化
 Carson帶你學(xué)Android：功能防抖
 Carson帶你學(xué)Android：從磁盤/內(nèi)存緩存中獲取緩存數(shù)據(jù)
Carson帶你學(xué)Android：聯(lián)合判斷

歡迎關(guān)注Carson_Ho的簡書

不定期分享關(guān)于安卓開發(fā)的干貨佳晶，追求短桅狠、平、快轿秧，但卻不缺深度中跌。

請點贊！因為你的鼓勵是我寫作的最大動力菇篡！

最后編輯于：2021.09.17 22:08:08

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者

人面猴
序言：七十年代末漩符，一起剝皮案震驚了整個濱河市，隨后出現(xiàn)的幾起案子驱还，更是在濱河造成了極大的恐慌嗜暴，老刑警劉巖，帶你破解...
沈念sama閱讀 206,968評論 6贊 482
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件议蟆，死亡現(xiàn)場離奇詭異闷沥，居然都是意外死亡，警方通過查閱死者的電腦和手機咐容，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 88,601評論 2贊 382
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門舆逃，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人戳粒，你說我怎么就攤上這事路狮。” “怎么了蔚约？”我有些...
開封第一講書人閱讀 153,220評論 0贊 344
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵奄妨，是天一觀的道長。經(jīng)常有香客問我苹祟，道長砸抛，這世上最難降的妖魔是什么评雌？我笑而不...
開封第一講書人閱讀 55,416評論 1贊 279
?港島之戀（遺憾婚禮）
正文為了忘掉前任，我火速辦了婚禮锰悼，結(jié)果婚禮上柳骄，老公的妹妹穿的比我還像新娘。我一直安慰自己箕般，他們只是感情好耐薯，可當(dāng)我...
茶點故事閱讀 64,425評論 5贊 374
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布。她就那樣靜靜地躺著丝里，像睡著了一般曲初。火紅的嫁衣襯著肌膚如雪。梳的紋絲不亂的頭發(fā)上杯聚，一...
開封第一講書人閱讀 49,144評論 1贊 285
城市分裂傳說
那天臼婆，我揣著相機與錄音，去河邊找鬼幌绍。笑死颁褂，一個胖子當(dāng)著我的面吹牛，可吹牛的內(nèi)容都是我干的傀广。我是一名探鬼主播颁独，決...
沈念sama閱讀 38,432評論 3贊 401
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼伪冰！你這毒婦竟也來了誓酒？” 一聲冷哼從身側(cè)響起，我...
開封第一講書人閱讀 37,088評論 0贊 261
萬榮殺人案實錄
序言：老撾萬榮一對情侶失蹤贮聂，失蹤者是張志新（化名）和其女友劉穎靠柑，沒想到半個月后，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體吓懈，經(jīng)...
沈念sama閱讀 43,586評論 1贊 300
?護(hù)林員之死
正文獨居荒郊野嶺守林人離奇死亡歼冰，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點故事閱讀 36,028評論 2贊 325
?白月光啟示錄
正文我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了耻警。大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片停巷。...
茶點故事閱讀 38,137評論 1贊 334
活死人
序言：一個原本活蹦亂跳的男人離奇死亡，死狀恐怖榕栏，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情蕾各，我是刑警寧澤扒磁，帶...
沈念sama閱讀 33,783評論 4贊 324
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布，位于F島的核電站式曲，受9級特大地震影響妨托，放射性物質(zhì)發(fā)生泄漏缸榛。R本人自食惡果不足惜，卻給世界環(huán)境...
茶點故事閱讀 39,343評論 3贊 307
男人毒藥：我在死后第九天來索命
文/蒙蒙一兰伤、第九天我趴在偏房一處隱蔽的房頂上張望内颗。院中可真熱鬧，春花似錦敦腔、人聲如沸均澳。這莊子的主人今日做“春日...
開封第一講書人閱讀 30,333評論 0贊 19
一樁弒父案符衔，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽找前。三九已至，卻和暖如春判族，著一層夾襖步出監(jiān)牢的瞬間躺盛，已是汗流浹背。一陣腳步聲響...
開封第一講書人閱讀 31,559評論 1贊 262
情欲美人皮
我被黑心中介騙來泰國打工形帮，沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留槽惫，地道東北人。一個月前我還...
沈念sama閱讀 45,595評論 2贊 355
代替公主和親
正文我出身青樓辩撑，卻偏偏與公主長得像界斜，于是被迫代替她去往敵國和親。傳聞我的和親對象是個殘疾皇子槐臀，可洞房花燭夜當(dāng)晚...
茶點故事閱讀 42,901評論 2贊 345

Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南

Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南

前言

目錄

1. RxJava簡介

2. 基本使用

2.1 方式1：分步驟實現(xiàn)

2.1.1 使用步驟

2.1.2 步驟詳解

步驟1：創(chuàng)建被觀察者（`Observable` ）& 生產(chǎn)事件

步驟2：創(chuàng)建觀察者（`Observer` ）并定義響應(yīng)事件的行為

步驟3：通過訂閱（`Subscribe`）連接觀察者和被觀察者

2.2 方式2：優(yōu)雅的實現(xiàn)方法 - 基于事件流的鏈?zhǔn)秸{(diào)用

特別注意

3. 實例講解

3.1 方式1：分步驟實現(xiàn)

3.2 方式2：基于事件流的鏈?zhǔn)秸{(diào)用方式

4. 額外說明

4.1 觀察者 Observer的subscribe()具備多個重載的方法

4.2 可采用 Disposable.dispose() 切斷觀察者與被觀察者之間的連接

5. 總結(jié)

歡迎關(guān)注Carson_Ho的簡書

請點贊！因為你的鼓勵是我寫作的最大動力菇篡！

推薦閱讀更多精彩內(nèi)容

Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南

前言

目錄

1. RxJava簡介

2. 基本使用

2.1 方式1：分步驟實現(xiàn)

2.1.1 使用步驟

2.1.2 步驟詳解

步驟1：創(chuàng)建被觀察者 （Observable ）& 生產(chǎn)事件

步驟2：創(chuàng)建觀察者 （Observer ）并 定義響應(yīng)事件的行為

步驟3：通過訂閱（Subscribe）連接觀察者和被觀察者

2.2 方式2：優(yōu)雅的實現(xiàn)方法 - 基于事件流的鏈?zhǔn)秸{(diào)用

特別注意

3. 實例講解

3.1 方式1：分步驟實現(xiàn)

3.2 方式2：基于事件流的鏈?zhǔn)秸{(diào)用方式

4. 額外說明

4.1 觀察者 Observer的subscribe()具備多個重載的方法

4.2 可采用 Disposable.dispose() 切斷觀察者 與 被觀察者 之間的連接

5. 總結(jié)

歡迎關(guān)注Carson_Ho的簡書

請點贊！因為你的鼓勵是我寫作的最大動力菇篡！

推薦閱讀更多精彩內(nèi)容

步驟1：創(chuàng)建被觀察者（`Observable` ）& 生產(chǎn)事件

步驟2：創(chuàng)建觀察者（`Observer` ）并定義響應(yīng)事件的行為

步驟3：通過訂閱（`Subscribe`）連接觀察者和被觀察者

4.2 可采用 Disposable.dispose() 切斷觀察者與被觀察者之間的連接