Contents

module EMJack
  module Handler
    class Reserved
      RESPONSE = /^(RESERVED|FOUND)\s+(\d+)\s+(\d+)\r\n/

      def self.handles?(response)
        if response =~ RESPONSE
          [true, $3.to_i]
        else
          false
        end
      end

      def self.handle(deferrable, response, body, conn)
        return false unless response =~ RESPONSE
        id = $2.to_i
        bytes = $3.to_i

        job = EMJack::Job.new(conn, id, body)
        deferrable.succeed(job)

        true
      end

      EMJack::Connection.register_handler(EMJack::Handler::Reserved)
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
em-jack-0.1.5	lib/em-jack/handlers/reserved.rb
em-jack-0.1.4	lib/em-jack/handlers/reserved.rb
em-jack-0.1.3	lib/em-jack/handlers/reserved.rb
em-jack-0.1.2	lib/em-jack/handlers/reserved.rb
em-jack-0.1.1	lib/em-jack/handlers/reserved.rb
em-jack-0.1.0	lib/em-jack/handlers/reserved.rb
em-jack-0.0.9	lib/em-jack/handlers/reserved.rb