Method: Fluent::Test::Driver::BaseOwner#event_streams

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

#event_streams(tag: nil) ⇒ Object 



91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/fluent/test/driver/base_owner.rb', line 91

def event_streams(tag: nil)
  return [] if @event_streams.nil?
  selected = @event_streams.select{|e| tag.nil? ? true : e.tag == tag }
  if block_given?
    selected.each do |e|
      yield e.tag, e.es
    end
  else
    selected.map{|e| [e.tag, e.es] }
  end
end