class Reacto::Operations::DelayEach::TaskObserver

Public Class Methods

new(tracker) click to toggle source
# File lib/reacto/operations/delay_each.rb, line 10
def initialize(tracker)
  @tracker = tracker
end

Public Instance Methods

update(time, result, e) click to toggle source
# File lib/reacto/operations/delay_each.rb, line 13
def update(time, result, e)
  if e
    @tracker.on_error(e) unless e.is_a?(Concurrent::TimeoutError)
  end
end