简化下 为了理解

Author: laileon

src/com/blankj/custom/rxjava/Observable.java

@@ -22,7 +22,7 @@ public static <T> Observable<T> create(OnSubscribe<T> onSubscribe) {
     }
 
     public void subscribe(Subscriber<T> subscriber) {
-        System.out.println("will call subscriber");
+        System.out.println("will call subscriber\n");
 //        subscriber.onStart();
         //onSubscribe来call这个subscriber
         onSubscribe.call(subscriber);

src/com/blankj/custom/rxjava/Test.java

@@ -6,7 +6,7 @@ public static void main(String[] args) {
             //实例化接口实现类，需要override
             @Override
             public void call(Subscriber<Integer> subscriber) {
-                System.out.println("call method execute");
+                System.out.println("call method execute\n");
                 for (int i = 0; i < 10; i++) {
                     System.out.println("Prepare data " + i);
                     subscriber.onNext(i);
@@ -27,7 +27,7 @@ public void onError(Throwable t) {
 
             @Override
             public void onNext(Integer var1) {
-                System.out.println(var1);
+                System.out.println("Received data " + var1);
             }
         });
     }