Correction for issue geopython#49

fsteggink · Sep 3, 2016 · cf4357d · cf4357d
1 parent 5995596
commit cf4357d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/stetl/filters/xmlassembler.py b/stetl/filters/xmlassembler.py
@@ -39,6 +39,10 @@ def invoke(self, packet):
             # Valid element: consume and handle
             self.consume_element(packet)
 
+            # Document is obviously not finished, reset EoD/EoS in packet
+            packet.set_end_of_stream(False)
+            packet.set_end_of_doc(False)
+
         if packet.is_end_of_stream() or packet.is_end_of_doc() or len(self.element_arr) >= self.max_elements:
             # EOF but still data in buffer: make doc
             # log.info("Flush doc")