合并接口第三次上传

common/src/main/java/com/yunbao/common/http/API.java

@@ -63,9 +63,9 @@ public class API extends BaseApi {
         loggingInterceptor.setPrintLevel(HttpLoggingInterceptor.Level.BODY);
         OkHttpClient.Builder builder = new OkHttpClient()
                 .newBuilder()
+
                 .addInterceptor(initQuery(isNeedUid,CommonAppContext.sInstance.getApplicationContext()))
                 .addInterceptor(loggingInterceptor);
-
         return create(builder.build(),
                 GsonConverterFactory.create(gson), RxJava2CallAdapterFactory.create(), CommonAppConfig.HOST, PDLiveApi.class);
     }

common/src/main/java/com/yunbao/common/http/PDLiveApi.java

@@ -324,11 +324,12 @@ public interface PDLiveApi {
             @Query("GroupId") String GroupId,
             @Query("stream") String stream
     );
+
     /**
      * 加入房间推送Im欢迎语
      */
     @GET("/api/public/?service=Tx.leaveRoomNew")
-    Observable<ResponseModel<String>> leaveRoomNew(
+    Observable<ResponseModel<List<Object>>> leaveRoomNew(
             @Query("GroupId") String GroupId,
             @Query("stream") String stream
     );

common/src/main/java/com/yunbao/common/http/live/LiveNetManager.java

@@ -25,6 +25,7 @@ import com.yunbao.common.http.base.HttpCallback;
 import java.util.List;
 
 import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
 import io.reactivex.functions.Consumer;
 import io.reactivex.schedulers.Schedulers;
 
@@ -361,14 +362,17 @@ public class LiveNetManager {
      * @param city
      * @param callback
      */
+    private Disposable enterRoomDisposable = null;
+
     public void enterRoomNew(String stream, String liveUid, String city, HttpCallback<EnterRoomNewModel> callback) {
-        API.get().pdLiveApi(mContext)
+        enterRoomDisposable = API.get().pdLiveApi(mContext)
                 .enterRoomNew("g" + liveUid, stream, liveUid, city)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Consumer<ResponseModel<EnterRoomNewModel>>() {
                     @Override
                     public void accept(ResponseModel<EnterRoomNewModel> enterRoomNewModelResponseModel) throws Exception {
+                        enterRoomDisposable = null;
                         if (callback != null) {
                             callback.onSuccess(enterRoomNewModelResponseModel.getData().getInfo());
                         }
@@ -376,11 +380,12 @@ public class LiveNetManager {
                 }, new Consumer<Throwable>() {
                     @Override
                     public void accept(Throwable throwable) throws Exception {
+                        enterRoomDisposable = null;
                         if (callback != null) {
                             callback.onError(throwable.getMessage());
                         }
                     }
-                }).isDisposed();
+                });
     }
 
     /**
@@ -389,22 +394,24 @@ public class LiveNetManager {
      * @param stream
      * @param liveUid
      */
+    private Disposable userJoinDisposable = null;
+
     public void userJoinRoomNew(String stream, String liveUid) {
-        API.get().pdLiveApi(mContext)
+        userJoinDisposable = API.get().pdLiveApi(mContext)
                 .userJoinRoomNew("g" + liveUid, stream)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Consumer<ResponseModel<String>>() {
                     @Override
                     public void accept(ResponseModel<String> stringResponseModel) throws Exception {
-
+                        userJoinDisposable = null;
                     }
                 }, new Consumer<Throwable>() {
                     @Override
                     public void accept(Throwable throwable) throws Exception {
-
+                        userJoinDisposable = null;
                     }
-                }).isDisposed();
+                });
     }
 
     /**
@@ -413,16 +420,16 @@ public class LiveNetManager {
      * @param stream
      * @param liveUid
      */
-    public void leaveRoomNew(String stream, String liveUid,HttpCallback<String> callback) {
+    public void leaveRoomNew(String stream, String liveUid, HttpCallback<String> callback) {
         API.get().pdLiveApi(mContext)
-                .userJoinRoomNew("g" + liveUid, stream)
+                .leaveRoomNew("g" + liveUid, stream)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
-                .subscribe(new Consumer<ResponseModel<String>>() {
+                .subscribe(new Consumer<ResponseModel<List<Object>>>() {
                     @Override
-                    public void accept(ResponseModel<String> stringResponseModel) throws Exception {
+                    public void accept(ResponseModel<List<Object>> listResponseModel) throws Exception {
                         if (callback != null) {
-                            callback.onSuccess("");
+                            callback.onError("");
                         }
                     }
                 }, new Consumer<Throwable>() {
@@ -434,4 +441,16 @@ public class LiveNetManager {
                     }
                 }).isDisposed();
     }
+
+    /**
+     * 直播间取消网络请求
+     */
+    public void cancelLive() {
+        if (userJoinDisposable != null) {
+            userJoinDisposable.dispose();
+        }
+        if (enterRoomDisposable != null) {
+            enterRoomDisposable.dispose();
+        }
+    }
 }