add demo5

Author: Carson-Ho

.idea/misc.xml

@@ -2,15 +2,6 @@
 
 import android.os.Bundle;
 import android.support.v7.app.AppCompatActivity;
-import android.util.Log;
-
-import java.util.concurrent.TimeUnit;
-
-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 {
@@ -22,51 +13,51 @@ protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_main);
 
-        Observable.create(new ObservableOnSubscribe<Integer>() {
-            @Override
-            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
-                // 隔段事件发送时间
-                e.onNext(1);
-                Thread.sleep(500);
-
-                e.onNext(2);
-
-                Thread.sleep(1500);
-
-                e.onNext(3);
-                Thread.sleep(1500);
-
-                e.onNext(4);
-                Thread.sleep(500);
-                e.onNext(5);
-                Thread.sleep(500);
-                e.onNext(6);
-                Thread.sleep(1500);
-
-                e.onComplete();
-            }
-        }).throttleWithTimeout(1, TimeUnit.SECONDS)//每1秒中采用数据
-                .subscribe(new Observer<Integer>() {
-                    @Override
-                    public void onSubscribe(Disposable d) {
-
-                    }
-
-                    @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事件作出响应");
-                    }
-                });
+//        Observable.create(new ObservableOnSubscribe<Integer>() {
+//            @Override
+//            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
+//                // 隔段事件发送时间
+//                e.onNext(1);
+//                Thread.sleep(500);
+//
+//                e.onNext(2);
+//
+//                Thread.sleep(1500);
+//
+//                e.onNext(3);
+//                Thread.sleep(1500);
+//
+//                e.onNext(4);
+//                Thread.sleep(500);
+//                e.onNext(5);
+//                Thread.sleep(500);
+//                e.onNext(6);
+//                Thread.sleep(1500);
+//
+//                e.onComplete();
+//            }
+//        }).throttleWithTimeout(1, TimeUnit.SECONDS)//每1秒中采用数据
+//                .subscribe(new Observer<Integer>() {
+//                    @Override
+//                    public void onSubscribe(Disposable d) {
+//
+//                    }
+//
+//                    @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事件作出响应");
+//                    }
+//                });