# File lib/fluent/command/cat.rb, line 93 def initialize(writer) @writer = writer end
# File lib/fluent/command/cat.rb, line 107 def run until @finish sleep 1 @writer.on_timer end end
# File lib/fluent/command/cat.rb, line 102 def shutdown @finish = true @thread.join end
# File lib/fluent/command/cat.rb, line 97 def start @finish = false @thread = Thread.new(&method(:run)) end