Contents

module ZooniverseSocial
  class TaskObserver
    def initialize(task, restart)
      @task = task
      @restart = restart
      @task.add_observer self
    end

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

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
zooniverse_social-1.3.1	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.2.0	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.1.0	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.6	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.5	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.4	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.3	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.2	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.1	lib/zooniverse_social/task_observer.rb
zooniverse_social-1.0.0	lib/zooniverse_social/task_observer.rb