code: def wait(self, limit=None):
          
          it = self.iterconsume(limit)
          while True:
              it.next()
docs: Go into consume mode.
  
          Mostly for testing purposes and simple programs, you probably
          want :meth:`iterconsume` or :meth:`iterqueue` instead.
  
          This runs an infinite loop, processing all incoming messages
          using :meth:`receive` to apply the message to all registered
          callbacks.