fix duplication of events in tests

This commit is contained in:
Jordan Sissel 2012-10-04 13:08:59 -07:00
parent dd735b80e9
commit 2d8b877883

View file

@ -45,10 +45,12 @@ module LogStash
results = []
event.each do |e|
filters.each do |filter|
next if e.cancelled?
filter.filter(e)
results << e unless e.cancelled?
end
results << e unless e.cancelled?
end
filters.select { |f| f.respond_to?(:flush) }.each do |filter|
event = filter.flush
results += event if event