新增同步请求方式execute()

lannaican · Mar 13, 2020 · ad52193 · ad52193
1 parent 00abc6f
commit ad52193
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/api/src/main/java/com/star/api/adapter/CallBack.java b/api/src/main/java/com/star/api/adapter/CallBack.java
@@ -37,6 +37,10 @@ public CallBack(Observable<T> observable) {
         this.observable = observable;
     }
 
+    public Observable<T> getObservable() {
+        return observable;
+    }
+
     /**
      * 设置监听器
      */
@@ -104,6 +108,13 @@ public void go() {
                 .subscribe(this);
     }
 
+    /**
+     * 同步执行
+     */
+    public T execute() {
+        return observable.blockingFirst();
+    }
+
     /**
      * 获取回调
      */