diff --git a/index.js b/index.js
index f190c689..b4870587 100644
--- a/index.js
+++ b/index.js
@@ -85,7 +85,7 @@ function compression (options) {
       }
 
       return stream
-        ? stream.write(Buffer.from(chunk, encoding))
+        ? stream.write(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk, encoding))
         : _write.call(this, chunk, encoding)
     }
 
@@ -112,7 +112,7 @@ function compression (options) {
 
       // write Buffer for Node.js 0.8
       return chunk
-        ? stream.end(Buffer.from(chunk, encoding))
+        ? stream.end(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk, encoding))
         : stream.end()
     }