add demo

Author: Carson-Ho

.idea/misc.xml

@@ -26,7 +26,9 @@ dependencies {
     })
     compile 'com.android.support:appcompat-v7:25.3.1'
     compile 'com.android.support.constraint:constraint-layout:1.0.2'
-    compile 'io.reactivex.rxjava2:rxjava:2.0.1'
-    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
+    compile 'io.reactivex:rxandroid:1.2.0'
+    compile 'io.reactivex:rxjava:1.1.5'
+//    compile 'io.reactivex.rxjava2:rxjava:2.0.1'
+//    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
     testCompile 'junit:junit:4.12'
 }

app/build.gradle

@@ -2,13 +2,7 @@
 
 import android.os.Bundle;
 import android.support.v7.app.AppCompatActivity;
-import android.util.Log;
 
-import io.reactivex.Observable;
-import io.reactivex.ObservableEmitter;
-import io.reactivex.ObservableOnSubscribe;
-import io.reactivex.Observer;
-import io.reactivex.disposables.Disposable;
 
 public class MainActivity extends AppCompatActivity {
 
@@ -19,44 +13,72 @@ protected void onCreate(Bundle savedInstanceState) {
         setContentView(R.layout.activity_main);
 
 
-// 1. 通过creat（）创建被观察者对象
-        Observable.create(new ObservableOnSubscribe<Integer>() {
-            // 2. 在复写的subscribe（）里定义需要发送的事件
-            @Override
-            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
-                emitter.onNext(1);
-                emitter.onNext(2);
-                emitter.onNext(3);
-                emitter.onNext(4);
+//        Observable.create(new Observable.OnSubscribe<Integer>() {
+//            @Override
+//            public void call(Subscriber<? super Integer> subscriber) {
+//                  // 不发送任何有效事件
+//                  // subscriber.onNext(1);
+//                  // subscriber.onNext(2);
+//                  // subscriber.onNext(3);
+//
+//                subscriber.onCompleted();
+//                // 仅发送Complete事件
+//            }
+//        }).defaultIfEmpty(10) // 若仅发送了Complete事件，默认发送 值 = 10
+//                .subscribe(new Subscriber<Integer>() {
+//                    @Override
+//                    public void onCompleted() {
+//                        Log.v(TAG, "onCompleted");
+//                    }
+//                    @Override
+//                    public void onError(Throwable e) {
+//                        Log.v(TAG, "onError:"+e.getMessage());
+//                    }
+//                    @Override
+//                    public void onNext(Integer integer) {
+//                        Log.v(TAG, "onNext:"+integer);
+//                    }
+//                });
 
-                emitter.onComplete();
-            }  // 至此，一个被观察者对象（Observable）就创建完毕
-        }).subscribe(new Observer<Integer>() {
-            // 以下步骤仅为展示一个完整demo，可以忽略
-            // 3. 通过通过订阅（subscribe）连接观察者和被观察者
-            // 4. 创建观察者 & 定义响应事件的行为
-            @Override
-            public void onSubscribe(Disposable d) {
-                Log.d(TAG, "开始采用subscribe连接");
-            }
-            // 默认最先调用复写的 onSubscribe（）
-
-            @Override
-            public void onNext(Integer value) {
-                Log.d(TAG, "接收到了事件"+ value  );
-            }
-
-            @Override
-            public void onError(Throwable e) {
-                Log.d(TAG, "对Error事件作出响应");
-            }
-
-            @Override
-            public void onComplete() {
-                Log.d(TAG, "对Complete事件作出响应");
-            }
-
-        });
+//
+//// 1. 通过creat（）创建被观察者对象
+//        Observable.create(new ObservableOnSubscribe<Integer>() {
+//            // 2. 在复写的subscribe（）里定义需要发送的事件
+//            @Override
+//            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
+//                emitter.onNext(1);
+//                emitter.onNext(2);
+//                emitter.onNext(3);
+//                emitter.onNext(4);
+//
+//                emitter.onComplete();
+//            }  // 至此，一个被观察者对象（Observable）就创建完毕
+//        }).subscribe(new Observer<Integer>() {
+//            // 以下步骤仅为展示一个完整demo，可以忽略
+//            // 3. 通过通过订阅（subscribe）连接观察者和被观察者
+//            // 4. 创建观察者 & 定义响应事件的行为
+//            @Override
+//            public void onSubscribe(Disposable d) {
+//                Log.d(TAG, "开始采用subscribe连接");
+//            }
+//            // 默认最先调用复写的 onSubscribe（）
+//
+//            @Override
+//            public void onNext(Integer value) {
+//                Log.d(TAG, "接收到了事件"+ value  );
+//            }
+//
+//            @Override
+//            public void onError(Throwable e) {
+//                Log.d(TAG, "对Error事件作出响应");
+//            }
+//
+//            @Override
+//            public void onComplete() {
+//                Log.d(TAG, "对Complete事件作出响应");
+//            }
+//
+//        });
     }
 
     }