diff --git a/stetl/filters/xmlassembler.py b/stetl/filters/xmlassembler.py
index 38d4be7..95040a5 100644
--- 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")