Sha256: 4cc0fa65228113ddba2cac72ed747cb7efbbe86a453857d2c21128540d8fe16e
Contents?: true
Size: 841 Bytes
Versions: 1
Compression:
Stored size: 841 Bytes
Contents
# frozen_string_literal: true module ClockworkMocks class ClockworkTask def initialize(interval, name, hash, block) @interval = interval @name = name @hash = hash || {} @block = block @due = calc_due end def reset! @due = Time.now.utc @due = calc_due end def perform(handler = nil) if @block @block.call elsif handler handler.call(@name, Time.now.utc) end @due = calc_due end attr_reader :due, :name private def calc_due ndue = Time.at((due || Time.now.utc).to_f + @interval).utc return ndue unless @hash[:at] at_split = @hash[:at].split(':').map(&:to_i) new_due = ndue.change(hour: at_split[0], minute: at_split[1]) new_due <= ndue ? new_due : (new_due - 1.day) end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
clockwork-mocks-1.3.1 | lib/clockwork_mocks/clockwork_task.rb |