Class: Ruflet::Rails::Protocol::WireCodec::ByteReader

Inherits:
Object
  • Object
show all
Defined in:
lib/ruflet/rails/protocol/wire_codec.rb

Instance Method Summary collapse

Constructor Details

#initialize(bytes) ⇒ ByteReader

Returns a new instance of ByteReader.



215
216
217
218
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 215

def initialize(bytes)
  @data = bytes.to_s.b
  @offset = 0
end

Instance Method Details

#read_binary(size) ⇒ Object 



246
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 246

def read_binary(size) = read_exact(size)

#read_exact(size) ⇒ Object 



228
229
230
231
232
233
234
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 228

def read_exact(size)
  chunk = @data.byteslice(@offset, size)
  raise "Unexpected EOF" if chunk.nil? || chunk.bytesize != size

  @offset += size
  chunk
end

#read_f32 ⇒ Object 



243
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 243

def read_f32 = read_exact(4).unpack1("g")

#read_f64 ⇒ Object 



244
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 244

def read_f64 = read_exact(8).unpack1("G")

#read_i16 ⇒ Object 



240
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 240

def read_i16 = read_exact(2).unpack1("s>")

#read_i32 ⇒ Object 



241
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 241

def read_i32 = read_exact(4).unpack1("l>")

#read_i64 ⇒ Object 



242
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 242

def read_i64 = read_exact(8).unpack1("q>")

#read_i8 ⇒ Object 



239
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 239

def read_i8 = read_exact(1).unpack1("c")

#read_string(size) ⇒ Object 



245
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 245

def read_string(size) = read_exact(size).force_encoding("UTF-8")

#read_u16 ⇒ Object 



236
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 236

def read_u16 = read_exact(2).unpack1("n")

#read_u32 ⇒ Object 



237
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 237

def read_u32 = read_exact(4).unpack1("N")

#read_u64 ⇒ Object 



238
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 238

def read_u64 = read_exact(8).unpack1("Q>")

#read_u8 ⇒ Object 



220
221
222
223
224
225
226
 
# File 'lib/ruflet/rails/protocol/wire_codec.rb', line 220

def read_u8
  value = @data.getbyte(@offset)
  raise "Unexpected EOF" if value.nil?

  @offset += 1
  value
end