@@ -119,11 +119,11 @@
 // and decompresses data according to the predictor algorithm
 func Decompressor(reader io.Reader) io.Reader {
 	var ctx context
 	ctx.input = make([]byte, 0, 8)
 
-	return iou.BlockReader(iou.ReaderFunc(func(output []byte) (int, error) {
+	return iou.SizedReader(iou.ReaderFunc(func(output []byte) (int, error) {
 		var (
 			err               error
 			flags, predicted  byte
 			rc, total, copied int
 		)