docs: add `mapExecute` implementation to fastify examples plugin

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

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 ece9b8cf77456eecfc87c303c4d170351e1da59d..22a55053626a2736ece91ff7de469c7ccb02e34e 100644 (file)
--- 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 a9156566ef6025ebf4799e21bbe7e7ba6cd7b7ec..0a92fe09117295f8b5a2e137f21ea81de00f7c0f 100644 (file)
--- 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()
 }