lib/fluent/test/output_test.rb in fluentd-0.10.8 vs lib/fluent/test/output_test.rb in fluentd-0.10.9

@@ -110,15 +110,21 @@
   end
 
   def run(&block)
     result = []
     super {
+      buffer = ''
       @entries.keys.each {|key|
         es = ArrayEventStream.new(@entries[key])
         @instance.emit(@tag, es, NullOutputChain.instance)
+        buffer << @instance.format_stream(@tag, es)
       }
 
       block.call if block
+
+      if @expected_buffer
+        assert_equal(@expected_buffer, buffer)
+      end
 
       chunks = @instance.instance_eval {
         @buffer.instance_eval {
           chunks = []
           @map.keys.each {|key|