46c595168cabd5ce99981748204c53de4ffe0261,src/gluonnlp/data/stream.py,_Prefetcher,__next__,#_Prefetcher#,233

Before Change

    def __next__(self):
        next_item = self.data_queue.get()
        if next_item is None:
            self.control_queue.put(None)
            raise StopIteration
        return next_item

    def next(self):

After Change

        // the error queue
        next_error = self._errorq.get(block=False)

        if next_error is None:
            return next_item
        else:
            self._controlq.put(None)
            if next_error[0] is StopIteration:
                raise StopIteration
            else:
                return self._reraise(*next_error)

    def _reraise(self, e, tb):
        print("Reraising exception from Prefetcher")
        print(tb)
        raise e

Instances