46c595168cabd5ce99981748204c53de4ffe0261,src/gluonnlp/data/stream.py,_Prefetcher,run,#_Prefetcher#,212

Before Change

            try:
                data = next(stream_iter)
                self.data_queue.put(data)
            except StopIteration:
                self.data_queue.put(None)

    def __next__(self):

After Change

                    raise RuntimeError("Got unexpected control code {}".format(repr(c)))
            except queue.Empty:
                pass
            except RuntimeError as e:
                tb = traceback.format_exc()
                self._dataq.put(None)
                self._errorq.put((e, tb))

            try:

Instances