chore(release): publish

 - csv-demo-esm@0.0.15
 - csv-issues-esm@0.0.6
 - csv-parse@5.3.4
 - csv@6.2.6

demo/esm/CHANGELOG.md

@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.0.15](https://github.com/adaltas/node-csv/compare/csv-demo-esm@0.0.14...csv-demo-esm@0.0.15) (2023-01-31)
+
+**Note:** Version bump only for package csv-demo-esm
+
+
+
+
+
 ## [0.0.14](https://github.com/adaltas/node-csv/compare/csv-demo-esm@0.0.13...csv-demo-esm@0.0.14) (2022-11-30)
 
 **Note:** Version bump only for package csv-demo-esm

demo/esm/package.json

@@ -1,13 +1,13 @@
 {
   "name": "csv-demo-esm",
-  "version": "0.0.14",
+  "version": "0.0.15",
   "main": "index.js",
   "license": "MIT",
   "type": "module",
   "private": true,
   "dependencies": {
-    "csv": "^6.2.5",
-    "csv-parse": "^5.3.3"
+    "csv": "^6.2.6",
+    "csv-parse": "^5.3.4"
   },
   "devDependencies": {
     "coffeescript": "^2.7.0",

demo/issues-esm/CHANGELOG.md

@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.0.6](https://github.com/adaltas/node-csv/compare/csv-issues-esm@0.0.5...csv-issues-esm@0.0.6) (2023-01-31)
+
+**Note:** Version bump only for package csv-issues-esm
+
+
+
+
+
 ## [0.0.5](https://github.com/adaltas/node-csv/compare/csv-issues-esm@0.0.4...csv-issues-esm@0.0.5) (2022-11-08)
 
 **Note:** Version bump only for package csv-issues-esm

demo/issues-esm/package.json

@@ -1,6 +1,6 @@
 {
   "name": "csv-issues-esm",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "main": "index.js",
   "license": "MIT",
   "type": "module",

packages/csv-parse/CHANGELOG.md

@@ -3,6 +3,15 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [5.3.4](https://github.com/adaltas/node-csv/compare/csv-parse@5.3.3...csv-parse@5.3.4) (2023-01-31)
+
+
+### Bug Fixes
+
+* **csv-parse:** destroy on end and call close event (fix [#333](https://github.com/adaltas/node-csv/issues/333)) ([ca3f55b](https://github.com/adaltas/node-csv/commit/ca3f55b7cf556b45377677428783608a2d9ebbb2))
+
+
+
 ## [5.3.3](https://github.com/adaltas/node-csv/compare/csv-parse@5.3.2...csv-parse@5.3.3) (2022-11-28)
 
 

packages/csv-parse/package.json

@@ -1,5 +1,5 @@
 {
-  "version": "5.3.3",
+  "version": "5.3.4",
   "name": "csv-parse",
   "description": "CSV parsing implementing the Node.js `stream.Transform` API",
   "keywords": [

packages/csv/CHANGELOG.md

@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [6.2.6](https://github.com/adaltas/node-csv/compare/csv@6.2.5...csv@6.2.6) (2023-01-31)
+
+**Note:** Version bump only for package csv
+
+
+
+
+
 ## [6.2.5](https://github.com/adaltas/node-csv/compare/csv@6.2.4...csv@6.2.5) (2022-11-30)
 
 **Note:** Version bump only for package csv

packages/csv/dist/cjs/index.cjs

@@ -1575,9 +1575,10 @@ class Parser extends stream.Transform {
       return;
     }
     const err = this.api.parse(buf, false, (record) => {
-      this.push.call(this, record);
+      this.push(record);
     }, () => {
-      this.push.call(this, null);
+      this.push(null);
+      this.on('end', this.destroy);
     });
     if(err !== undefined){
       this.state.stop = true;
@@ -1590,9 +1591,10 @@ class Parser extends stream.Transform {
       return;
     }
     const err = this.api.parse(undefined, true, (record) => {
-      this.push.call(this, record);
+      this.push(record);
     }, () => {
-      this.push.call(this, null);
+      this.push(null);
+      this.on('end', this.destroy);
     });
     callback(err);
   }

packages/csv/dist/esm/index.js

@@ -6702,9 +6702,10 @@ class Parser extends Transform {
       return;
     }
     const err = this.api.parse(buf, false, (record) => {
-      this.push.call(this, record);
+      this.push(record);
     }, () => {
-      this.push.call(this, null);
+      this.push(null);
+      this.on('end', this.destroy);
     });
     if(err !== undefined){
       this.state.stop = true;
@@ -6717,9 +6718,10 @@ class Parser extends Transform {
       return;
     }
     const err = this.api.parse(undefined, true, (record) => {
-      this.push.call(this, record);
+      this.push(record);
     }, () => {
-      this.push.call(this, null);
+      this.push(null);
+      this.on('end', this.destroy);
     });
     callback(err);
   }

packages/csv/dist/iife/index.js

@@ -6705,9 +6705,10 @@ var csv = (function (exports) {
                   return;
                 }
                 const err = this.api.parse(buf, false, (record) => {
-                  this.push.call(this, record);
+                  this.push(record);
                 }, () => {
-                  this.push.call(this, null);
+                  this.push(null);
+                  this.on('end', this.destroy);
                 });
                 if(err !== undefined){
                   this.state.stop = true;
@@ -6720,9 +6721,10 @@ var csv = (function (exports) {
                   return;
                 }
                 const err = this.api.parse(undefined, true, (record) => {
-                  this.push.call(this, record);
+                  this.push(record);
                 }, () => {
-                  this.push.call(this, null);
+                  this.push(null);
+                  this.on('end', this.destroy);
                 });
                 callback(err);
               }

packages/csv/dist/umd/index.js

@@ -6708,9 +6708,10 @@
                   return;
                 }
                 const err = this.api.parse(buf, false, (record) => {
-                  this.push.call(this, record);
+                  this.push(record);
                 }, () => {
-                  this.push.call(this, null);
+                  this.push(null);
+                  this.on('end', this.destroy);
                 });
                 if(err !== undefined){
                   this.state.stop = true;
@@ -6723,9 +6724,10 @@
                   return;
                 }
                 const err = this.api.parse(undefined, true, (record) => {
-                  this.push.call(this, record);
+                  this.push(record);
                 }, () => {
-                  this.push.call(this, null);
+                  this.push(null);
+                  this.on('end', this.destroy);
                 });
                 callback(err);
               }

packages/csv/package.json

@@ -1,6 +1,6 @@
 {
   "name": "csv",
-  "version": "6.2.5",
+  "version": "6.2.6",
   "description": "A mature CSV toolset with simple api, full of options and tested against large datasets.",
   "keywords": [
     "node",
@@ -22,7 +22,7 @@
   ],
   "dependencies": {
     "csv-generate": "^4.2.1",
-    "csv-parse": "^5.3.3",
+    "csv-parse": "^5.3.4",
     "csv-stringify": "^6.2.3",
     "stream-transform": "^3.2.1"
   },