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