Skip to content

Commit

Permalink
Merge pull request #53 from fsteggink/issue_49_correction
Browse files Browse the repository at this point in the history
Thanks for the Issue 49 correction. Yes agree we should work on #51 as to remove redundant functionality and future bugs.
  • Loading branch information
justb4 authored Sep 4, 2016
2 parents 42a63be + bc0a691 commit f1fc82b
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions stetl/filters/xmlassembler.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit f1fc82b

Please sign in to comment.