class Fluent::Plugin::NullOutput
def try_write(chunk)
def try_write(chunk) raise "failed to flush" if @never_flush if @feed_proc @feed_proc.call(chunk) end # not to commit chunks for testing # commit_write(chunk.unique_id) end
def try_write(chunk) raise "failed to flush" if @never_flush if @feed_proc @feed_proc.call(chunk) end # not to commit chunks for testing # commit_write(chunk.unique_id) end