Merge dependabot/npm_and_yarn/examples/typescript/smtp-client-pool/nodemailer-6.9...

[poolifier.git] / examples / typescript / smtp-client-pool / src / pool.ts

diff --git a/examples/typescript/smtp-client-pool/src/pool.ts b/examples/typescript/smtp-client-pool/src/pool.ts
index f73094471fb017a3d385e5561168b7b38b5f2a21..2fc53c980b20b9f26590e3408382f88cd86ada62 100644 (file)
--- a/examples/typescript/smtp-client-pool/src/pool.ts
+++ b/examples/typescript/smtp-client-pool/src/pool.ts
@@ -1,24 +1,23 @@
 import { fileURLToPath } from 'node:url'
 import { dirname, extname, join } from 'node:path'
 import { DynamicThreadPool, availableParallelism } from 'poolifier'
-import { type WorkerData } from './types.js'
+import type SMTPTransport from 'nodemailer/lib/smtp-transport/index.js'
+import type { WorkerData } from './types.js'
 
 const workerFile = join(
   dirname(fileURLToPath(import.meta.url)),
   `worker${extname(fileURLToPath(import.meta.url))}`
 )
 
-export const smtpClientPool = new DynamicThreadPool<WorkerData>(
-  1,
-  availableParallelism(),
-  workerFile,
-  {
-    enableTasksQueue: true,
-    tasksQueueOptions: {
-      concurrency: 8
-    },
-    errorHandler: (e: Error) => {
-      console.error('Thread worker error:', e)
-    }
+export const smtpClientPool = new DynamicThreadPool<
+WorkerData,
+SMTPTransport.SentMessageInfo
+>(0, availableParallelism(), workerFile, {
+  enableTasksQueue: true,
+  tasksQueueOptions: {
+    concurrency: 8
+  },
+  errorHandler: (e: Error) => {
+    console.error('Thread worker error:', e)
   }
-)
+})