createServer

typescript

function createServer(
  startupData: WorkerThreadsStartupData,
  options: ServerOptions
): Promise<WorkerThreadsServerChannel>

Create a worker threads server for worker-side communication.

This function uses parentPort from worker_threads to establish communication with the host process.

Parameters

Name	Type	Description
startupData	WorkerThreadsStartupData	Startup data from the host process
options	ServerOptions	Server options

Returns

Promise<WorkerThreadsServerChannel>

Examples

typescript

import { WorkerThreadsDriver } from 'isolated-workers/drivers/worker-threads';

const startupData = WorkerThreadsDriver.getStartupData();
const server = createServer(startupData);

server.onMessage(async (message, respond) => {
  console.log('Received:', message);
  await respond({
    tx: message.tx,
    type: message.type,
    payload: { result: 'ok' },
  });
});

server.start();

← Back to CreateServer