Sha256: 305fa8322921959644351a190c66cf5728532d580aef754fc85cb26a6cf15ed7
Contents?: true
Size: 1.97 KB
Versions: 13
Compression:
Stored size: 1.97 KB
Contents
# encoding: utf-8
#:stopdoc:
# this file was autogenerated on 2011-07-21 07:07:06 +0100
#
# DO NOT EDIT! (edit ext/qparser.rb and config.yml instead, and run 'ruby qparser.rb')
module Qrack
module Transport09
class Frame
FOOTER = 206
ID = 0
@types = {
1 => 'Method',
2 => 'Header',
3 => 'Body',
8 => 'Heartbeat',
}
attr_accessor :channel, :payload
def initialize payload = nil, channel = 0
@channel, @payload = channel, payload
end
def id
self.class::ID
end
def to_binary
buf = Transport09::Buffer.new
buf.write :octet, id
buf.write :short, channel
buf.write :longstr, payload
buf.write :octet, FOOTER
buf.rewind
buf
end
def to_s
to_binary.to_s
end
def == frame
[ :id, :channel, :payload ].inject(true) do |eql, field|
eql and __send__(field) == frame.__send__(field)
end
end
def self.parse buf
buf = Transport09::Buffer.new(buf) unless buf.is_a? Transport09::Buffer
buf.extract do
id, channel, payload, footer = buf.read(:octet, :short, :longstr, :octet)
Qrack::Transport09.const_get(@types[id]).new(payload, channel) if footer == FOOTER
end
end
end
class Method < Frame
ID = 1
def initialize payload = nil, channel = 0
super
unless @payload.is_a? Protocol09::Class::Method or @payload.nil?
@payload = Protocol09.parse(@payload)
end
end
end
class Header < Frame
ID = 2
def initialize payload = nil, channel = 0
super
unless @payload.is_a? Protocol09::Header or @payload.nil?
@payload = Protocol09::Header.new(@payload)
end
end
end
class Body < Frame
ID = 3
end
class Heartbeat < Frame
ID = 8
end
end
end
Version data entries
13 entries across 13 versions & 2 rubygems