@@ -29,16 +29,16 @@
 		buf bytes.Buffer
 		err error
 	)
 
 	out := Compressor(&buf)
-	err = out(input)
+	_, err = out.Write(input)
 	if err != nil {
 		t.Error(err)
 	}
 
-	err = out(nil)
+	_, err = out.Write(nil)
 	if err != nil {
 		t.Error(err)
 	}
 
 	result := buf.Bytes()
@@ -109,11 +109,11 @@
 	for len(data) > 0 {
 		if step <= len(data) {
 
 			trace = append(trace, data[:step]...)
 
-			err = compressor(data[:step])
+			_, err = compressor.Write(data[:step])
 			if err != nil {
 				return err
 			}
 			data = data[step:]
 		} else {
@@ -120,11 +120,11 @@
 			step = len(data)
 		}
 	}
 
 	// Flush the compressor
-	err = compressor(nil)
+	_, err = compressor.Write(nil)
 	if err != nil {
 		return err
 	}
 
 	// Attempt to decompress the data