Class: Reacto::Operations::DelayEach::TaskObserver

Inherits:

Object

• Object
• Reacto::Operations::DelayEach::TaskObserver

Defined in:

lib/reacto/operations/delay_each.rb

Instance Method Summary

• #initialize(tracker) ⇒ TaskObserver constructor

  A new instance of TaskObserver.

• #update(time, result, e) ⇒ Object

Constructor Details

#initialize(tracker) ⇒ TaskObserver

Returns a new instance of TaskObserver.

# File 'lib/reacto/operations/delay_each.rb', line 10

def initialize(tracker)
  @tracker = tracker
end

Instance Method Details

#update(time, result, e) ⇒ Object

# 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