em_worker.rb

require 'eventmachine'
require 'ruote/worker'

module Ruote
  class EMWorker < Worker

    def run
      EM.add_periodic_timer(1) do
        step
      end
    end

    def run_in_thread
      raise NotImplementedError, 'EMWorker#run_in_thread'
    end

    def shutdown
      EM.stop
    end

    def take_a_rest(msgs_processed)
    end
  end
end