From 3924d83878275190248eb13b8f814b82c7dde655 Mon Sep 17 00:00:00 2001
From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= <jerome.benoit@piment-noir.org>
Date: Fri, 30 Aug 2024 17:37:37 +0200
Subject: [PATCH] docs: add `mapExecute` implementation to fastify examples
 plugin
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---
 .../fastify-hybrid/src/fastify-poolifier.ts           | 11 +++++++++++
 .../fastify-worker_threads/src/fastify-poolifier.ts   | 11 +++++++++++
 2 files changed, 22 insertions(+)

diff --git a/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-poolifier.ts b/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-poolifier.ts
index ece9b8cf..22a55053 100644
--- a/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-poolifier.ts
+++ b/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-poolifier.ts
@@ -45,6 +45,17 @@ const fastifyPoolifierPlugin: FastifyPluginCallback<FastifyPoolifierOptions> = (
         await pool.execute(data, name, transferList)
     )
   }
+  if (!fastify.hasDecorator('mapExecute')) {
+    fastify.decorate(
+      'mapExecute',
+      async (
+        data: Iterable<ThreadWorkerData>,
+        name?: string,
+        transferList?: readonly TransferListItem[]
+      ): Promise<ThreadWorkerResponse[]> =>
+        await pool.mapExecute(data, name, transferList)
+    )
+  }
   done()
 }
 
diff --git a/examples/typescript/http-server-pool/fastify-worker_threads/src/fastify-poolifier.ts b/examples/typescript/http-server-pool/fastify-worker_threads/src/fastify-poolifier.ts
index a9156566..0a92fe09 100644
--- a/examples/typescript/http-server-pool/fastify-worker_threads/src/fastify-poolifier.ts
+++ b/examples/typescript/http-server-pool/fastify-worker_threads/src/fastify-poolifier.ts
@@ -44,6 +44,17 @@ const fastifyPoolifierPlugin: FastifyPluginCallback<FastifyPoolifierOptions> = (
       ): Promise<WorkerResponse> => await pool.execute(data, name, transferList)
     )
   }
+  if (!fastify.hasDecorator('mapExecute')) {
+    fastify.decorate(
+      'mapExecute',
+      async (
+        data: Iterable<WorkerData>,
+        name?: string,
+        transferList?: readonly TransferListItem[]
+      ): Promise<WorkerResponse[]> =>
+        await pool.mapExecute(data, name, transferList)
+    )
+  }
   done()
 }
 
-- 
2.34.1