Class: Avro::IPC::FramedWriter

Inherits:
Object
  • Object
show all
Defined in:
lib/avro/ipc.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(writer) ⇒ FramedWriter

Returns a new instance of FramedWriter.



465
466
467
 
# File 'lib/avro/ipc.rb', line 465

def initialize(writer)
  @writer = writer
end

Instance Attribute Details

#writer ⇒ Object (readonly)

Returns the value of attribute writer.



464
465
466
 
# File 'lib/avro/ipc.rb', line 464

def writer
  @writer
end

Instance Method Details

#to_s ⇒ Object 



484
 
# File 'lib/avro/ipc.rb', line 484

def to_s; writer.string; end

#write_framed_message(message) ⇒ Object 



469
470
471
472
473
474
475
476
477
478
479
480
481
482
 
# File 'lib/avro/ipc.rb', line 469

def write_framed_message(message)
  message_size = message.size
  total_bytes_sent = 0
  while message_size - total_bytes_sent > 0
    if message_size - total_bytes_sent > BUFFER_SIZE
      buffer_size = BUFFER_SIZE
    else
      buffer_size = message_size - total_bytes_sent
    end
    write_buffer(message[total_bytes_sent, buffer_size])
    total_bytes_sent += buffer_size
  end
  write_buffer_size(0)
end