class Protobuf::Rpc::Socket::Worker

def read_data
  size_io = StringIO.new
  until (size_reader = @socket.getc) == "-"
    size_io << size_reader
  end
  str_size_io = size_io.string
  "#{str_size_io}-#{@socket.read(str_size_io.to_i)}"
end