Sha256: d01c4321e6524e64f77d0ddc364bf8f0816a073e6b407d0da9d65fe200c8e348

Contents?: true

Size: 506 Bytes

Versions: 9

Compression:

Stored size: 506 Bytes

Contents

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

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

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

        deferrable.succeed(YAML.load(body))
        true
      end

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

Version data entries

9 entries across 9 versions & 1 rubygems

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