lib/fusuma/plugin/inputs/timer_input.rb in fusuma-3.6.0 vs lib/fusuma/plugin/inputs/timer_input.rb in fusuma-3.6.1

- old
+ new

@@ -21,25 +21,24 @@ super(*args) @interval = interval || config_params(:interval) || DEFAULT_INTERVAL @early_wake_queue = Queue.new end - attr_reader :pid, :interval + attr_reader :interval def io @io ||= begin reader, writer = create_io - @pid = start(reader, writer) + start(reader, writer) reader end end def start(reader, writer) Thread.new do timer_loop(writer) end - nil end def timer_loop(writer) delta_t = @interval next_wake = Time.now + delta_t