Sha256: 0aa86d20bcd4f92a935be379d3ae2339e8fbdd6d79bd83e02dd1ee68ed923950

Contents?: true

Size: 429 Bytes

Versions: 2

Compression:

Stored size: 429 Bytes

Contents

module EMJack
  module Handler
    class Buried
      RESPONSE = /^BURIED\s+(\d+)\r\n/

      def self.handles?(response)
        response =~ RESPONSE
      end

      def self.handle(deferrable, response, body, conn=nil)
        return false unless response =~ RESPONSE

        deferrable.fail(:buried, $1.to_i)
        true
      end
      
      EMJack::Connection.register_handler(EMJack::Handler::Buried)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
em-jack-0.0.8 lib/em-jack/handlers/buried.rb
em-jack-0.0.7 lib/em-jack/handlers/buried.rb