def pipe()

in darabonba/utils/stream.py [0:0]

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

    def pipe(self, output_stream, buffer_size=1024):
        if not isinstance(output_stream, Stream):
            raise TypeError("Output stream should be an instance of Stream.")
        
        while True:
            chunk = self.read(buffer_size)
            if not chunk:
                break
            output_stream.write(chunk)