class Protobuf::Rpc::Connectors::Socket

def read_response
  log_debug { sign_message("error? is #{error?}") }
  return if error?
  response_buffer = ::Protobuf::Rpc::Buffer.new(:read)
  response_buffer << read_data
  @stats.response_size = response_buffer.size
  @response_data = response_buffer.data
  parse_response if response_buffer.flushed?
end