code: def clean(self):
          
          # Note that we do not close the connection here -- somebody
          # may still be reading from it.
          while len(self.queue) > 0 and self._pair_stale(self.queue[0]):
              self.queue.pop(0)
docs: Get rid of stale connections.