patch fd

pinojs · Mar 21, 2019 · 3a10bf0 · 3a10bf0
1 parent 9242190
commit 3a10bf0
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/lib/transport.js b/lib/transport.js
@@ -2,10 +2,15 @@
 
 const { Worker } = require('worker_threads')
 
-function transport (name, args = []) {
-  const filename = require.resolve(name)
-  const worker = new Worker(filename, {
-    execArgv: args,
+function transport (filePath, args = []) {
+  args.unshift(filePath)
+  const code = `
+    process.stdin.fd = 1
+    process.argv.push(...${JSON.stringify(args)})
+    require('${filePath}')
+  `
+  const worker = new Worker(code, {
+    eval: true,
     stdin: true
   })
   return worker.stdin