code: def triggered(self, walker):
          
  
          if self.use_count:
              comp_value = walker.count()
          else:
              if walker.count() == 0:
                  return False
  
              comp_value = walker.peek().value
  
          return self.comp_function(comp_value, self.reference)
docs: Check if this input is triggered on the given stream walker.
  
          Args:
              walker (StreamWalker): The walker to check
  
          Returns:
              bool: Whether this trigger is triggered or not