diff --git a/index.js b/index.js
index e550bd4..0f35715 100644
--- a/index.js
+++ b/index.js
@@ -4,7 +4,10 @@ var gen = require('generate-object-property')
 
 var CsvWriteStream = function(opts) {
   if (!opts) opts = {}
-  stream.Transform.call(this, {objectMode:true, highWaterMark:16})
+  stream.Transform.call(this, {
+    objectMode: true,
+    highWaterMark: opts.highWaterMark || 16
+  })
 
   this.sendHeaders = opts.sendHeaders !== false
   this.headers = opts.headers || null