Merge branch 'close-parse-on-stopped'

wanglingsong · Jul 21, 2021 · 8d28d6b · 8d28d6b
2 parents a4a1c5b + f1cfd83
commit 8d28d6b
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 0 deletions.
diff --git a/jsurfer-fastjson/src/main/java/org/jsfr/json/FastJsonParser.java b/jsurfer-fastjson/src/main/java/org/jsfr/json/FastJsonParser.java
@@ -144,6 +144,11 @@ private void doParse() {
                 if (tempString != null) {
                     context.primitive(staticPrimitiveHolder.withValue(tempString));
                 }
+
+                if (context.isStopped()) {
+                    lexer.close();
+                }
+
             } catch (Exception e) {
                 context.getConfig().getErrorHandlingStrategy().handleParsingException(e);
             }

diff --git a/jsurfer-gson/src/main/java/org/jsfr/json/GsonParser.java b/jsurfer-gson/src/main/java/org/jsfr/json/GsonParser.java
@@ -124,6 +124,9 @@ private void doParse() {
                             break;
                     }
                 }
+                if (context.isStopped()) {
+                    jsonReader.close();
+                }
             } catch (Exception e) {
                 context.getConfig().getErrorHandlingStrategy().handleParsingException(e);
             }

diff --git a/jsurfer-jackson/src/main/java/org/jsfr/json/JacksonParser.java b/jsurfer-jackson/src/main/java/org/jsfr/json/JacksonParser.java
@@ -200,6 +200,9 @@ void doPare() throws IOException {
                         throw new IllegalStateException("Unexpected token");
                 }
             }
+            if (context.isStopped()) {
+                this.jsonParser.close();
+            }
         }
 
     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -200,6 +200,9 @@ void doPare() throws IOException { @@
                             throw new IllegalStateException("Unexpected token");
                     }
                 }
+                if (context.isStopped()) {
+                    this.jsonParser.close();
+                }
             }
         }
@@ Expand Down @@