Class: Ruflet::WireCodec::ByteReader

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

Instance Method Summary collapse

Constructor Details

#initialize(bytes) ⇒ ByteReader

Returns a new instance of ByteReader.



264
265
266
267
 
# File 'lib/ruflet/server/wire_codec.rb', line 264

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

Instance Method Details

#read_binary(size) ⇒ Object 



325
326
327
 
# File 'lib/ruflet/server/wire_codec.rb', line 325

def read_binary(size)
  read_exact(size)
end

#read_exact(size) ⇒ Object 



277
278
279
280
281
282
283
 
# File 'lib/ruflet/server/wire_codec.rb', line 277

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 



313
314
315
 
# File 'lib/ruflet/server/wire_codec.rb', line 313

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

#read_f64 ⇒ Object 



317
318
319
 
# File 'lib/ruflet/server/wire_codec.rb', line 317

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

#read_i16 ⇒ Object 



301
302
303
 
# File 'lib/ruflet/server/wire_codec.rb', line 301

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

#read_i32 ⇒ Object 



305
306
307
 
# File 'lib/ruflet/server/wire_codec.rb', line 305

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

#read_i64 ⇒ Object 



309
310
311
 
# File 'lib/ruflet/server/wire_codec.rb', line 309

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

#read_i8 ⇒ Object 



297
298
299
 
# File 'lib/ruflet/server/wire_codec.rb', line 297

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

#read_string(size) ⇒ Object 



321
322
323
 
# File 'lib/ruflet/server/wire_codec.rb', line 321

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

#read_u16 ⇒ Object 



285
286
287
 
# File 'lib/ruflet/server/wire_codec.rb', line 285

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

#read_u32 ⇒ Object 



289
290
291
 
# File 'lib/ruflet/server/wire_codec.rb', line 289

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

#read_u64 ⇒ Object 



293
294
295
 
# File 'lib/ruflet/server/wire_codec.rb', line 293

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

#read_u8 ⇒ Object 



269
270
271
272
273
274
275
 
# File 'lib/ruflet/server/wire_codec.rb', line 269

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

  @offset += 1
  value
end