From cf4357d09c69899df611db0cc28fb556d8e38d84 Mon Sep 17 00:00:00 2001
From: Frank Steggink <frank@steggink.org>
Date: Sat, 3 Sep 2016 16:38:35 +0200
Subject: [PATCH] Correction for issue #49

---
 stetl/filters/xmlassembler.py | 4 ++++
 1 file changed, 4 insertions(+)

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")