Flush on exit

lib/transport.js

@@ -42,19 +42,35 @@ function buildStream (filename, workerData, workerOpts) {
     workerOpts
   })
 
-  stream.on('ready', function () {
+  stream.on('ready', onReady)
+  stream.on('close', function () {
+    process.removeListener('exit', onExit)
+  })
+
+  process.on('exit', onExit)
+
+  function onReady () {
+    process.removeListener('exit', onExit)
     stream.unref()
 
     if (workerOpts.autoEnd !== false) {
       setupOnExit(stream)
     }
-  })
+  }
+
+  function onExit () {
+    if (stream.closed) {
+      return
+    }
+    stream.flushSync()
+  }
 
   return stream
 }
 
 function autoEnd (stream) {
   stream.ref()
+  stream.flushSync()
   stream.end()
   stream.once('close', function () {
     stream.unref()

test/fixtures/transport-exit-immediately.js

@@ -0,0 +1,10 @@
+'use strict'
+
+const pino = require('../..')
+const transport = pino.transport({
+  target: 'pino/file'
+})
+const logger = pino(transport)
+
+logger.info('Hello')
+process.exit(0)

test/fixtures/transport-exit-on-ready.js

@@ -0,0 +1,12 @@
+'use strict'
+
+const pino = require('../..')
+const transport = pino.transport({
+  target: 'pino/file'
+})
+const logger = pino(transport)
+
+transport.on('ready', function () {
+  logger.info('Hello')
+  process.exit(0)
+})

test/transport/core.test.js

@@ -305,6 +305,30 @@ test('stdout in worker', async ({ not }) => {
   not(strip(actual).match(/Hello/), null)
 })
 
+test('log and exit on ready', async ({ not }) => {
+  let actual = ''
+  const child = execa(process.argv[0], [join(__dirname, '..', 'fixtures', 'transport-exit-on-ready.js')])
+
+  child.stdout.pipe(writer((s, enc, cb) => {
+    actual += s
+    cb()
+  }))
+  await once(child, 'close')
+  not(strip(actual).match(/Hello/), null)
+})
+
+test('log and exit before ready', async ({ not }) => {
+  let actual = ''
+  const child = execa(process.argv[0], [join(__dirname, '..', 'fixtures', 'transport-exit-immediately.js')])
+
+  child.stdout.pipe(writer((s, enc, cb) => {
+    actual += s
+    cb()
+  }))
+  await once(child, 'close')
+  not(strip(actual).match(/Hello/), null)
+})
+
 test('pino transport options with target', async ({ teardown, same }) => {
   const destination = join(
     os.tmpdir(),