docs: def process_forever(self, timeout=0.2):
          """Run an infinite loop, processing data from connections.
  
          This method repeatedly calls process_once.
  
          Arguments:
  
              timeout -- Parameter to pass to process_once.
          """
          # This loop should specifically *not* be mutex-locked.
          # Otherwise no other thread would ever be able to change
          # the shared state of a Reactor object running this function.
          log.debug("process_forever(timeout=%s)", timeout)
          one = functools.partial(self.process_once, timeout=timeout)
          consume(infinite_call(one))