We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 42a63be + bc0a691 commit f1fc82bCopy full SHA for f1fc82b
stetl/filters/xmlassembler.py
@@ -39,6 +39,10 @@ def invoke(self, packet):
39
# Valid element: consume and handle
40
self.consume_element(packet)
41
42
+ # Document is obviously not finished, reset EoD/EoS in packet
43
+ packet.set_end_of_stream(False)
44
+ packet.set_end_of_doc(False)
45
+
46
if packet.is_end_of_stream() or packet.is_end_of_doc() or len(self.element_arr) >= self.max_elements:
47
# EOF but still data in buffer: make doc
48
# log.info("Flush doc")
0 commit comments