14 . 增加了两个readme文件；连载小说和读者；一个复杂一些的应用场景。

Author: liuhuan2015

app/src/main/java/com/liuh/learn/rxjava2/MainActivity.java

@@ -1,8 +1,12 @@
 package com.liuh.learn.rxjava2;
 
 import android.content.Intent;
+import android.graphics.Bitmap;
+import android.graphics.drawable.BitmapDrawable;
+import android.graphics.drawable.Drawable;
 import android.support.v7.app.AppCompatActivity;
 import android.os.Bundle;
+import android.util.Log;
 import android.view.View;
 
 import com.liuh.learn.rxjava2.usecase.RxCaseConcatActivity;
@@ -16,6 +20,16 @@
 
 import butterknife.ButterKnife;
 import butterknife.OnClick;
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.ObservableOnSubscribe;
+import io.reactivex.Observer;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.functions.Consumer;
+import io.reactivex.schedulers.Schedulers;
+
+import static java.lang.Thread.sleep;
 
 public class MainActivity extends AppCompatActivity {
 
@@ -28,7 +42,8 @@ protected void onCreate(Bundle savedInstanceState) {
 
     @OnClick({R.id.btn_rx_operators, R.id.btn_a_simple_http_request, R.id.btn_http_request_concat,
             R.id.btn_http_request_flatmap, R.id.btn_http_request_zip, R.id.btn_http_request_interval,
-            R.id.btn_http_request_debounce, R.id.btn_thread_scheduler})
+            R.id.btn_http_request_debounce, R.id.btn_thread_scheduler, R.id.btn_novel_reader,
+            R.id.btn_complex_use})
     void onViewClicked(View view) {
         switch (view.getId()) {
             case R.id.btn_rx_operators:
@@ -55,7 +70,104 @@ void onViewClicked(View view) {
             case R.id.btn_thread_scheduler:
                 startActivity(new Intent(this, RxCaseThreadSchedulerActivity.class));
                 break;
-
+            case R.id.btn_novel_reader:
+                novelAndReader();
+                break;
+            case R.id.btn_complex_use:
+                oneComplexUse();
+                break;
         }
     }
+
+    /**
+     * 观察者模式(连载小说和读者)
+     */
+    private void novelAndReader() {
+        Observable.create(new ObservableOnSubscribe<String>() {
+            @Override
+            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
+                emitter.onNext("连载1");
+                sleep(3000);
+                emitter.onNext("连载2");
+                emitter.onNext("连载3");
+
+            }
+        }).subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(new Observer<String>() {
+                    @Override
+                    public void onSubscribe(Disposable d) {
+
+                    }
+
+                    @Override
+                    public void onNext(String s) {
+                        Log.e("-----", "Observer : onNext : " + s);
+                    }
+
+                    @Override
+                    public void onError(Throwable e) {
+                        Log.e("-----", "Observer : onError");
+                    }
+
+                    @Override
+                    public void onComplete() {
+                        Log.e("-----", "Observer : onComplete");
+                    }
+                });
+    }
+
+
+    private int[] drawables = {R.drawable.icon_1, R.drawable.icon_2, R.drawable.icon_3, R.drawable.icon_4, R.drawable.icon_5,
+            R.drawable.icon_6, R.drawable.icon_7, R.drawable.icon_8, R.drawable.icon_9, R.drawable.icon_10};
+
+    /**
+     * 一个复杂一点的应用场景
+     */
+    private void oneComplexUse() {
+
+        Observable.create(new ObservableOnSubscribe<Drawable>() {
+            @Override
+            public void subscribe(ObservableEmitter<Drawable> emitter) throws Exception {
+                for (int i = 0; i < drawables.length; i++) {
+                    Drawable drawable = getResources().getDrawable(drawables[i]);
+
+                    // 第六张图片延时3秒后加载
+                    if (5 == i) {
+                        sleep(3000);
+                    }
+
+                    // 复制第七张图片到sd卡
+                    if (6 == i) {
+                        Bitmap bitmap = ((BitmapDrawable) drawable).getBitmap();
+                        saveBitmap(bitmap, "test.png", Bitmap.CompressFormat.PNG);
+                    }
+
+                    // 上传到网络
+                    if (7 == i) {
+                        uploadIcon(drawable);
+                    }
+                    emitter.onNext(drawable);
+                }
+                emitter.onComplete();
+            }
+        }).subscribeOn(Schedulers.io())
+                .subscribeOn(AndroidSchedulers.mainThread())
+                .subscribe(new Consumer<Drawable>() {
+                    @Override
+                    public void accept(Drawable drawable) throws Exception {
+                        // 回调后在UI界面上展示出来
+
+                    }
+                });
+
+    }
+
+    private void saveBitmap(Bitmap bitmap, String s, Bitmap.CompressFormat png) {
+
+    }
+
+    private void uploadIcon(Drawable drawable) {
+
+    }
 }

app/src/main/res/drawable-xhdpi/icon_1.png

@@ -56,4 +56,21 @@
         android:layout_height="wrap_content"
         android:text="线程调度" />
 
+    <View
+        android:layout_width="match_parent"
+        android:layout_height="1dp"
+        android:background="@android:color/holo_blue_light" />
+
+    <Button
+        android:id="@+id/btn_novel_reader"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:text="连载小说和读者" />
+
+    <Button
+        android:id="@+id/btn_complex_use"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:text="一个复杂一点的应用场景" />
+
 </LinearLayout>

app/src/main/res/drawable-xhdpi/icon_10.png

@@ -0,0 +1 @@
+>学习目标文章[这可能是最好的RxJava 2.x 入门教程](https://www.jianshu.com/p/a93c79e9f689)

app/src/main/res/drawable-xhdpi/icon_2.png

@@ -0,0 +1,33 @@
+>学习目标文章[RxJava2.0——从放弃到入门](https://www.jianshu.com/p/cd3557b1a474)
+
+### 1 . RxJava 2.x和RxJava 1.x的关系
+RxJava 2.x和RxJava 1.x的核心思想都是观察者模式，只不过RxJava 2.x在RxJava 1.x的基础上对一些方法进行了优化，方便开发者更好地的理解其编程思想；同时RxJava 2.x增加了一部分新的方法来解决1.x中存在的问题，比如背压等。
+#### 1.1 观察者模式
+举例：读者订阅了连载小说，当小说有了新的连载更新后会主动推送给读者，读者不用时刻盯着小说连载。这就是观察者模式。
+
+### 2 . RxJava 2.x的异步和链式编程
+
+**RxJava最常用的写法：异步 + 链式编程**
+
+RxJava是支持异步的，通过Scheduler（英文名为调度器）来控制线程，当没有设置Scheduler时，RxJava遵循哪个线程产生就在哪个线程消费的原则，也就是说线程不会发生变化，始终在同一个。
+
+一般使用RxJava的场景都是后台执行，前台调用，这就需要使用Scheduler来进行线程的调度了。
+
+observeOn(AndroidSchedulers.mainThread())：事件回调的线程在主线程。
+
+subscribeOn(Schedulers.io())：事件执行的线程在io线程（子线程）；这里也可以使用Schedulers.newThread()，但是io线程可以重用空闲的线程，因此多数情况下io()比newThread()更有效率。
+
+### 3 . RxJava的应用场景
+
+**所有用到异步的地方，都可以使用RxJava来完成**
+
+RxJava的好处：“随着程序逻辑变得越来越复杂，RxJava依然能够保持简洁”。
+
+比如：依次加载十张图片（加载图片是耗时过程），其中第六张延时3秒加载，第七张复制到sd卡中，第八张要上传至网络。如果是使用Handler，必然是各种嵌套，逻辑复杂得再看一眼都难受，但是如果是使用RxJava呢——不会有任何嵌套，逻辑依然简洁。
+
+
+
+
+
+
+