diff --git a/src/mixin/CsvWriterMixin.coffee b/src/mixin/CsvWriterMixin.coffee
index 6f3da8a..780f07c 100644
--- a/src/mixin/CsvWriterMixin.coffee
+++ b/src/mixin/CsvWriterMixin.coffee
@@ -64,6 +64,6 @@ CsvWriterMixin = (options) ->
 
     # Finishes writing the csv when the pump finishes.
     target.on 'end', ->
-      target._csv.writer.write(null)
+      target._csv.writer.end()
 
 module.exports = CsvWriterMixin