Method: LogStash::Codecs::IdentityMapCodec#flush

Defined in:
lib/logstash/codecs/identity_map_codec.rb

#flush(&block) ⇒ Object 



202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
 
# File 'lib/logstash/codecs/identity_map_codec.rb', line 202

def flush(&block)
  all_codecs.each do |codec|
    #let ruby do its default args thing
    if block_given?
      codec.flush(&block)
    else
      if codec.respond_to?(:auto_flush)
        codec.auto_flush
      else
        #try this, no guarantees
        codec.flush
      end
    end
  end
end