RyanJeson
diff --git a/‎app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java‎
Lines changed: 3 additions & 0 deletions b/‎app/build/generated/source/kapt/debug/rxhttp/wrapper/param/ObservableParser.java‎
Lines changed: 3 additions & 0 deletions
diff --git a/‎app/src/main/java/com/example/httpsender/entity/ErrorInfo.java‎
Lines changed: 2 additions & 0 deletions b/‎app/src/main/java/com/example/httpsender/entity/ErrorInfo.java‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt‎
Lines changed: 3 additions & 0 deletions b/‎rxhttp-compiler/src/main/java/com/rxhttp/compiler/ClassHelper.kt‎
Lines changed: 3 additions & 0 deletions
@@ -26,6 +26,7 @@
 import rxhttp.wrapper.entity.ProgressT;
 import rxhttp.wrapper.parse.StreamParser;
 import rxhttp.wrapper.parse.Parser;
+import rxhttp.wrapper.utils.LogUtil;
 
 public final class ObservableParser<T> extends Observable<T> {
 
@@ -103,6 +104,7 @@ public void onNext(Progress progress) {
                 try {
                     v = Objects.requireNonNull(parser.onParse(p.getResult()), "The onParse function returned a null value.");
                 } catch (Throwable t) {
+                    LogUtil.log(p.getResult().request().url().toString(), t);
                     fail(t);
                     return;
                 }
@@ -212,6 +214,7 @@ public void onNext(Progress progress) {
                     T t = Objects.requireNonNull(parser.onParse(progressT.getResult()), "The onParse function returned a null value.");
                     p = new ProgressT<>(t);
                 } catch (Throwable t) {
+                    LogUtil.log(progressT.getResult().request().url().toString(), t);
                     onError(t);
                     return;
                 }
 
@@ -46,6 +46,8 @@ public ErrorInfo(Throwable throwable) {
             String code = throwable.getLocalizedMessage();
             if ("416".equals(code)) {
                 errorMsg = "请求范围不符合要求";
+            } else {
+                errorMsg = throwable.getMessage();
             }
         } else if (throwable instanceof JsonSyntaxException) { //请求成功，但Json语法异常,导致解析失败
             errorMsg = "数据解析失败,请稍后再试";
 
@@ -489,6 +489,7 @@ object ClassHelper {
             import rxhttp.wrapper.entity.ProgressT;
             import rxhttp.wrapper.parse.StreamParser;
             import rxhttp.wrapper.parse.Parser;
+            import rxhttp.wrapper.utils.LogUtil;
 
             public final class ObservableParser<T> extends Observable<T> {
 
@@ -566,6 +567,7 @@ object ClassHelper {
                             try {
                                 v = Objects.requireNonNull(parser.onParse(p.getResult()), "The onParse function returned a null value.");
                             } catch (Throwable t) {
+                                LogUtil.log(p.getResult().request().url().toString(), t);
                                 fail(t);
                                 return;
                             }
@@ -675,6 +677,7 @@ object ClassHelper {
                                 T t = Objects.requireNonNull(parser.onParse(progressT.getResult()), "The onParse function returned a null value.");
                                 p = new ProgressT<>(t);
                             } catch (Throwable t) {
+                                LogUtil.log(progressT.getResult().request().url().toString(), t);
                                 onError(t);
                                 return;
                             }
Original file line number	Diff line number	Diff line change
`@@ -46,6 +46,8 @@ public ErrorInfo(Throwable throwable) {`
`46`	`46`	`String code = throwable.getLocalizedMessage();`
`47`	`47`	`if ("416".equals(code)) {`
`48`	`48`	`errorMsg = "请求范围不符合要求";`
	`49`	`+ } else {`
	`50`	`+ errorMsg = throwable.getMessage();`
`49`	`51`	`}`
`50`	`52`	`} else if (throwable instanceof JsonSyntaxException) { //请求成功，但Json语法异常,导致解析失败`
`51`	`53`	`errorMsg = "数据解析失败,请稍后再试";`