code: def __next__(self):
      while not self._current:
          val = self.queue.get()
          if val is sentinel:
              self._sentinel_count += 1
              if self._sentinel_count >= len(self.procs):
                  raise StopIteration
          else:
              self._current = list(reversed(val))
      return self.decode(self._current.pop())
  
file_path: gluonts/src/gluonts/nursery/glide/parallel.py
imports: import multiprocessing
  from functools import partial
  from toolz.itertoolz import partition_all
  from toolz.functoolz import identity
label_desc: Use image node_id 6 for calling the ParApplyIterator obj's underlying member method code with example usage: obj.__next__() and returns: self