node_modules/thread-stream/test/on-message.js

'use strict'

const { parentPort } = require('worker_threads')
const { Writable } = require('stream')

function run () {
  parentPort.once('message', function ({ text, takeThisPortPlease }) {
    takeThisPortPlease.postMessage(`received: ${text}`)
  })
  return new Writable({
    autoDestroy: true,
    write (chunk, enc, cb) {
      cb()
    }
  })
}

module.exports = run