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