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