@@ -56,24 +56,16 @@
 // Decompress the data from the given io.Reader and write it to the given io.Writer
 // I/O is buffered for better performance
 func decompress(output io.Writer, input io.Reader) int {
 	var (
 		err          error
-		buffer       io.Writer = iou.SizedWriter(output, 4096)
 		decompressor io.Reader = predictor.Decompressor(iou.SizedReader(input, 4096))
 	)
 
-	_, err = io.Copy(buffer, decompressor)
+	_, err = io.Copy(output, decompressor)
 	if err != nil {
 		fmt.Fprintln(os.Stderr, "Error while decompressing.\n", err)
 		return 1
 	}
 
-	// Flush the buffer
-	_, err = buffer.Write(nil)
-	if err != nil {
-		fmt.Fprintln(os.Stderr, "Error while flushing output buffer.\n", err)
-		return 1
-	}
-
 	return 0
 }