修复okhttp sockettimeout问题

puyang1017 · Jul 12, 2019 · 522f924 · 522f924
1 parent 4f6a091
commit 522f924
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/puymvpjava/src/main/java/com/android/puy/puymvpjava/net/ApiSubscriber.java b/puymvpjava/src/main/java/com/android/puy/puymvpjava/net/ApiSubscriber.java
@@ -3,9 +3,11 @@
 import com.google.gson.JsonParseException;
 import com.google.gson.JsonSyntaxException;
 import io.reactivex.subscribers.ResourceSubscriber;
+import okhttp3.OkHttpClient;
 import org.json.JSONException;
 import retrofit2.HttpException;
 
+import java.net.SocketTimeoutException;
 import java.net.UnknownHostException;
 
 
@@ -24,6 +26,11 @@ public void onError(Throwable e) {
                         || e instanceof JsonSyntaxException) {
                     error = new NetError(e, NetError.ParseError);
                 } else {
+                    if (e instanceof SocketTimeoutException) {
+                        for (OkHttpClient client : XApi.getInstance().getClientMap().values()) {
+                            client.connectionPool().evictAll();
+                        }
+                    }
                     if (e instanceof HttpException) {
                         error = new NetError(e, NetError.HttpError, ((HttpException) e).code());
                     } else {