code: def on_iteration(self):
          
          self._cancel_consumers_if_requested()
  
          if len(self._consumers) == 0:
              _log.debug('requesting stop after iteration')
              self.should_stop = True
docs: Kombu callback for each `drain_events` loop iteration.