class Protobuf::Rpc::Connectors::EMClient

def receive_data(data)
  log_debug { "[#{log_signature}] receive_data: %s" % data }
  @response_buffer << data
  @response_data = @response_buffer.data
  parse_response if(!@response_data.nil? && @response_buffer.flushed?)
end