Class: ZooniverseSocial::TaskObserver

Inherits:

Object

• Object
• ZooniverseSocial::TaskObserver

Defined in:

lib/zooniverse_social/task_observer.rb

Instance Method Summary

• #initialize(task, restart) ⇒ TaskObserver constructor

  A new instance of TaskObserver.

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

Constructor Details

#initialize(task, restart) ⇒ TaskObserver

Returns a new instance of TaskObserver.

# File 'lib/zooniverse_social/task_observer.rb', line 3

def initialize(task, restart)
  @task = task
  @restart = restart
  @task.add_observer self
end

Instance Method Details

#update(time, result, error) ⇒ Object

# File 'lib/zooniverse_social/task_observer.rb', line 9

def update(time, result, error)
  if error.is_a?(Concurrent::TimeoutError)
    @task.shutdown
    @restart.call
  end
end