|
@@ -9,6 +9,7 @@ import io.reactivex.Observer
|
|
|
import io.reactivex.disposables.Disposable
|
|
|
import org.json.JSONObject
|
|
|
import retrofit2.HttpException
|
|
|
+import java.lang.Exception
|
|
|
|
|
|
/**
|
|
|
* @author LDD
|
|
@@ -95,14 +96,20 @@ abstract class ConnectionObserver<T> : BaseObserver<T>(BaseApplication.appContex
|
|
|
abstract class BaseObserver<T>(private val context: Context) : Observer<T> {
|
|
|
|
|
|
override fun onSubscribe(disposable: Disposable) {
|
|
|
- if (VoiNetTool.getAPNType(this.context) == VoiNetTool.netType.noneNet) {
|
|
|
- disposable.dispose()
|
|
|
- this.onNoneNet()
|
|
|
- } else {
|
|
|
+ try {
|
|
|
+ if (VoiNetTool.getAPNType(this.context) == VoiNetTool.netType.noneNet) {
|
|
|
+ disposable.dispose()
|
|
|
+ this.onNoneNet()
|
|
|
+ } else {
|
|
|
+ this.onStart()
|
|
|
+ this.attachSubscribe(disposable)
|
|
|
+ }
|
|
|
+ } catch (e:Exception){
|
|
|
+ System.err.println(e.message)
|
|
|
+ } finally {
|
|
|
this.onStart()
|
|
|
this.attachSubscribe(disposable)
|
|
|
}
|
|
|
-
|
|
|
}
|
|
|
|
|
|
override fun onError(e: Throwable) {
|