Method: Fluent::Test::Driver::BaseOwner#events

Defined in:
lib/fluent/test/driver/base_owner.rb

#events(tag: nil) ⇒ Object 



73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/fluent/test/driver/base_owner.rb', line 73

def events(tag: nil)
  if block_given?
    event_streams(tag: tag) do |t, es|
      es.each do |time, record|
        yield t, time, record
      end
    end
  else
    list = []
    event_streams(tag: tag) do |t, es|
      es.each do |time, record|
        list << [t, time, record]
      end
    end
    list
  end
end