bom: work with sync module, fix #115

CHANGELOG.md

@@ -1,6 +1,11 @@
 
 # Changelog
 
+## Trunk
+
+Fix
+* bom: work with sync module, fix #115
+
 ## Version 5.5.0
 
 Feature:

lib/es5/index.js

@@ -112,10 +112,6 @@ function (_Transform) {
       records: 0
     };
 
-    if (options.bom === true) {
-      _this.push(bom_utf8);
-    }
-
     _assertThisInitialized(_this);
 
     return _this;
@@ -332,6 +328,7 @@ function (_Transform) {
 
 
       if (this.info.records === 0) {
+        this.bom();
         this.headers();
       } // Emit and stringify the record if an object or an array
 
@@ -374,6 +371,7 @@ function (_Transform) {
     key: "_flush",
     value: function _flush(callback) {
       if (this.info.records === 0) {
+        this.bom();
         this.headers();
       }
 
@@ -603,6 +601,15 @@ function (_Transform) {
 
       return csvrecord;
     }
+  }, {
+    key: "bom",
+    value: function bom() {
+      if (this.options.bom !== true) {
+        return;
+      }
+
+      this.push(bom_utf8);
+    }
   }, {
     key: "headers",
     value: function headers() {

lib/index.js

@@ -49,9 +49,6 @@ class Stringifier extends Transform {
     this.info = {
       records: 0
     }
-    if(options.bom === true){
-      this.push(bom_utf8)
-    }
     this
   }
   normalize(options){
@@ -221,6 +218,7 @@ class Stringifier extends Transform {
     }
     // Emit the header
     if(this.info.records === 0){
+      this.bom()
       this.headers()
     }
     // Emit and stringify the record if an object or an array
@@ -256,6 +254,7 @@ class Stringifier extends Transform {
   }
   _flush(callback){
     if(this.info.records === 0){
+      this.bom()
       this.headers()
     }
     callback()
@@ -383,6 +382,12 @@ class Stringifier extends Transform {
     }
     return csvrecord
   }
+  bom(){
+    if(this.options.bom !== true){
+      return
+    }
+    this.push(bom_utf8)
+  }
   headers(){
     if(this.options.header === false){
       return

lib/sync.js

@@ -18,8 +18,5 @@ module.exports = function(records, options={}){
     stringifier.write(record) 
   }
   stringifier.end()
-  const res = data.join('');
-  return options.bom
-    ? '\ufeff' + res
-    : res;
+  return data.join('')
 }