'Handle a request/response that needs to be analyzed
:param work_unit: Request and response in a tuple
:return: None'

def _consume(self, work_unit):

    (request, response) = work_unit
    if (not self.should_grep(request, response)):
        return
    self._run_observers(request, response)
    for plugin in self._consumer_plugins:
        try:
            plugin.grep_wrapper(request, response)
        except Exception as e:
            self.handle_exception('grep', plugin.get_name(), request, e)
