作為一個有理想的程序猿，既然大家都說 RxJava 這么好用,所以抽空必須好好學(xué)習(xí)。讀《給 Android 開發(fā)者的 RxJava 詳解》 摘要：

• 簡介：RxJava-------->異步
  一個在 Java VM 上使用可觀測的序列來組成異步的、基于事件的程序的庫
• 基本實現(xiàn)
  一、 創(chuàng)建觀察者：（兩種方式：Observer 、Subscriber，兩者效果等價）

Observer<String> observer = new Observer<String>() {
    @Override
    public void onNext(String s) {
        Log.d(tag, "Item: " + s);
    }

    @Override
    public void onCompleted() {
        Log.d(tag, "Completed!");
    }

    @Override
    public void onError(Throwable e) {
        Log.d(tag, "Error!");
    }
};

Subscriber<String> subscriber = new Subscriber<String>() {
    @Override
    public void onNext(String s) {
        Log.d(tag, "Item: " + s);
    }

    @Override
    public void onCompleted() {
        Log.d(tag, "Completed!");
    }

    @Override
    public void onError(Throwable e) {
        Log.d(tag, "Error!");
    }
};

二、 創(chuàng)建 Observable（被觀察者，它決定什么時候觸發(fā)事件以及觸發(fā)怎樣的事件）

1. 使用 create() 方法來創(chuàng)建一個 Observable ：

Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onNext("Hello");
        subscriber.onNext("Hi");
        subscriber.onNext("Aloha");
        subscriber.onCompleted();
    }
});

2. just(T...): 將傳入的參數(shù)依次發(fā)送出來, eg:
   Observable observable = Observable.just("Hello", "Hi", "Aloha");
3. from(T[]) / from(Iterable<? extends T>) : 將傳入的數(shù)組或 Iterable 拆分成具體對象后，依次發(fā)送出來, eg:

String[] words = {"Hello", "Hi", "Aloha"};
Observable observable = Observable.from(words);

三、Subscribe (訂閱,將觀察者與被觀察者聯(lián)系起來)

observable.subscribe(observer);
// 或者：
observable.subscribe(subscriber);

• subscribe() 還支持不完整定義的回調(diào)，RxJava 會自動根據(jù)定義創(chuàng)建出 Subscriber（訂閱者，即觀察者）eg:

Action1<String> onNextAction = new Action1<String>() {
    // onNext()
    @Override
    public void call(String s) {
        Log.d(tag, s);
    }
};
Action1<Throwable> onErrorAction = new Action1<Throwable>() {
    // onError()
    @Override
    public void call(Throwable throwable) {
        // Error handling
    }
};
Action0 onCompletedAction = new Action0() {
    // onCompleted()
    @Override
    public void call() {
        Log.d(tag, "completed");
    }
};

// 自動創(chuàng)建 Subscriber ，并使用 onNextAction 來定義 onNext()
observable.subscribe(onNextAction);
// 自動創(chuàng)建 Subscriber ，并使用 onNextAction 和 onErrorAction 來定義 onNext() 和 onError()
observable.subscribe(onNextAction, onErrorAction);
// 自動創(chuàng)建 Subscriber ，并使用 onNextAction、 onErrorAction 和 onCompletedAction 來定義 onNext()、 onError() 和 onCompleted()
observable.subscribe(onNextAction, onErrorAction, onCompletedAction);

• 線程控制 —— Scheduler

1. Schedulers.immediate(): 直接在當(dāng)前線程運行，相當(dāng)于不指定線程。這是默認(rèn)的 Scheduler。
2. Schedulers.newThread(): 總是啟用新線程，并在新線程執(zhí)行操作。
3. Schedulers.io(): I/O 操作（讀寫文件、讀寫數(shù)據(jù)庫、網(wǎng)絡(luò)信息交互等）所使用的 Scheduler。
4. Schedulers.computation(): 計算所使用的 Scheduler。
5. AndroidSchedulers.mainThread()，它指定的操作將在 Android 主線程運行。
   eg:

Observable.just(1, 2, 3, 4)
    .subscribeOn(Schedulers.io()) // 指定 subscribe() 發(fā)生在 IO 線程
    .observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回調(diào)發(fā)生在主線程
    .subscribe(new Action1<Integer>() {
        @Override
        public void call(Integer number) {
            Log.d(tag, "number:" + number);
        }
    });

• 變換（map()、flatMap()）

1. map() ,一對一的轉(zhuǎn)化, eg:

Observable.just("images/logo.png") // 輸入類型 String
    .map(new Func1<String, Bitmap>() {
        @Override
        public Bitmap call(String filePath) { // 參數(shù)類型 String
            return getBitmapFromPath(filePath); // 返回類型 Bitmap
        }
    })
    .subscribe(new Action1<Bitmap>() {
        @Override
        public void call(Bitmap bitmap) { // 參數(shù)類型 Bitmap
            showBitmap(bitmap);
        }
    });

這里出現(xiàn)了一個叫做 Func1 的類。它和 Action1 非常相似，也是 RxJava 的一個接口，用于包裝含有一個參數(shù)的方法。 Func1 和 Action 的區(qū)別在于， Func1 包裝的是有返回值的方法。另外，和 ActionX 一樣， FuncX 也有多個，用于不同參數(shù)個數(shù)的方法。FuncX 和 ActionX 的區(qū)別在 FuncX 包裝的是有返回值的方法。

2. flatMap() , 一對多的轉(zhuǎn)化, eg:

Student[] students = ...;
Subscriber<Course> subscriber = new Subscriber<Course>() {
    @Override
    public void onNext(Course course) {
        Log.d(tag, course.getName());
    }
    ...
};
Observable.from(students)
    .flatMap(new Func1<Student, Observable<Course>>() {
        @Override
        public Observable<Course> call(Student student) {
            return Observable.from(student.getCourses());
        }
    })
    .subscribe(subscriber);

日常主要用到的兩個變換函數(shù)

• 最后，《給 Android 開發(fā)者的 RxJava 詳解》 這篇文章好長好長，要耐著性子看，一次不了然，多看幾次。。。