read_more_command

danielaparker · Nov 6, 2024 · 3d57996 · 3d57996
1 parent d8d15e1
commit 3d57996
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 7 deletions.
diff --git a/include/jsoncons/json_parser.hpp b/include/jsoncons/json_parser.hpp
@@ -33,8 +33,9 @@ class read_more_command
 {
 public:
     virtual ~read_more_command() = default;
-    virtual void read_more(std::error_code& ec)
+    virtual bool read_more(std::error_code&)
     {
+        return false;
     }
 };
 
@@ -2311,16 +2312,17 @@ class basic_json_parser : public ser_context
         {
             string_buffer_.append(sb,input_ptr_-sb);
             position_ += (input_ptr_ - sb);
-            //state_ = json_parse_state::string;
-            more_command_->read_more(ec);
+            if (!more_command_->read_more(ec))
+            {
+                return;
+            }
             if (ec)
             {
                 return;
             }
             local_input_end = end_input_;
             sb = input_ptr_;
             goto string_u1;
-            //return;
         }
 
 escape:

diff --git a/include/jsoncons/json_reader.hpp b/include/jsoncons/json_reader.hpp
@@ -267,18 +267,20 @@ namespace jsoncons {
         {
         }
 
-        virtual void read_more(std::error_code& ec)
+        virtual bool read_more(std::error_code& ec)
         {
-            std::cout << "UPDATE BUFFER\n";
+            //std::cout << "UPDATE BUFFER\n";
+            bool success = false;
             if (!parser_.stopped())
             {
                 if (parser_.source_exhausted())
                 {
                     auto s = source_.read_buffer(ec);
-                    if (ec) return;
+                    if (ec) return false;
                     if (s.size() > 0)
                     {
                         parser_.update(s.data(),s.size());
+                        success = true;
                     }
                 }
                 /*bool eof = parser_.source_exhausted();
@@ -297,6 +299,7 @@ namespace jsoncons {
                     }
                 }*/
             }
+            return success;
         }
 
         void read_next()