def decode()

in torchdata/datapipes/iter/util/plain_text_reader.py [0:0]

• 6 lines of code
• 4 McCabe index (conditional complexity)

    def decode(self, stream: Union[Iterator[bytes], Iterator[str]]) -> Union[Iterator[bytes], Iterator[str]]:
        if not self._decode:
            yield from stream
            return

        for line in stream:
            yield line.decode(self._encoding, self._errors) if isinstance(line, bytes) else line