docs: def _worker_method(self):
          """
          The body of the multi-get worker. Loops until
          :meth:`_should_quit` returns ``True``, taking tasks off the
          input queue, fetching the object, and putting them on the
          output queue.
          """
          while not self._should_quit():
              try:
                  task = self._inq.get(block=True, timeout=0.25)
              except TypeError:
                  if self._should_quit():
                      break
                  else:
                      raise
              except Empty:
                  continue
  
              try:
                  btype = task.client.bucket_type(task.bucket_type)
                  obj = btype.bucket(task.bucket).get(task.key, **task.options)
                  task.outq.put(obj)
              except KeyboardInterrupt:
                  raise
              except Exception as err:
                  errdata = (task.bucket_type, task.bucket, task.key, err)
                  task.outq.put(errdata)
              finally:
                  self._inq.task_done()