rxjava like

Author: laileon

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

@@ -1,5 +1,23 @@
 package com.blankj.custom.rxjava;
 
 public class Observable<T> {
+    final OnSubscribe<T> onSubscribe;
+
+    private Observable(OnSubscribe<T> onSubscribe) {
+        this.onSubscribe = onSubscribe;
+    }
+
+    public static <T> Observable<T> create(OnSubscribe<T> onSubscribe) {
+        return new Observable<T>(onSubscribe);
+    }
+
+    public void subscribe(Subscriber<? super T> subscriber) {
+        subscriber.onStart();
+        onSubscribe.call(subscriber);
+    }
+
+    public interface OnSubscribe<T> {
+        void call(Subscriber<? super T> subscriber);
+    }
 
 }

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

@@ -0,0 +1,27 @@
+package com.blankj.custom.rxjava;
+
+public class Test {
+    public static void main(String[] args) {
+        Observable.create(new Observable.OnSubscribe<Integer>() {
+            @Override
+            public void call(Subscriber<? super Integer> subscriber) {
+                for (int i = 0; i < 10; i++) {
+                    subscriber.onNext(i);
+                }
+            }
+        }).subscribe(new Subscriber<Integer>() {
+            @Override
+            public void onCompleted() {
+
+            }
+            @Override
+            public void onError(Throwable t) {
+
+            }
+            @Override
+            public void onNext(Integer var1) {
+                System.out.println(var1);
+            }
+        });
+    }
+}