v12 support

pinojs · Jul 23, 2021 · 2d662c7 · 2d662c7
1 parent 339f25f
commit 2d662c7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/lib/transport.js b/lib/transport.js
@@ -19,9 +19,11 @@ function setupOnExit (stream) {
     })
   } else {
     const fn = autoEnd.bind(null, stream)
-    process.on('exit', fn)
+    process.once('beforeExit', fn)
+    process.once('exit', fn)
 
     stream.on('close', function () {
+      process.removeListener('beforeExit', fn)
       process.removeListener('exit', fn)
     })
   }

diff --git a/test/fixtures/transport-worker.js b/test/fixtures/transport-worker.js
@@ -3,6 +3,7 @@
 const { Writable } = require('stream')
 module.exports = (options) => {
   const myTransportStream = new Writable({
+    autoDestroy: true,
     write (chunk, enc, cb) {
       console.log(chunk.toString())
       cb()