rxjava like

Author: laileon

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

@@ -10,6 +10,8 @@ private Observable(OnSubscribe<T> onSubscribe) {
 
 // 每个Observable里面有一个OnSubscribe对象，只有一个方法（void call(Subscriber<? super T> subscriber);），
 // 用来产生数据流，这是典型的命令模式。
+
+//  <T>  告诉编译器我这个地方有个类型
     public static <T> Observable<T> create(OnSubscribe<T> onSubscribe) {
         return new Observable<T>(onSubscribe);
     }

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

@@ -1,6 +1,7 @@
 package com.blankj.custom.rxjava;
 
 public abstract class Subscriber<T> implements Observer<T> {
+    //抽象类可以抽象方法，或者具体实现，此处为具体实现
     public void onStart() {
     }
 }