Skip to content

NodeWorker

Parent-side Node.js support for Effect workers.

layerPlatform installs the WorkerPlatform used by a Node program that owns workers. It supports both node:worker_threads workers and IPC-enabled child processes, routing messages through Effect's worker protocol. layer combines that platform with a Spawner callback, and the platform asks workers to close on scope finalization before forcefully terminating them on timeout.

2 exports Added in v4.0.0 Source

Layers

layer

Added in v4.0.0 Source

Provides the Node WorkerPlatform together with a Worker.Spawner created from the supplied worker or child-process spawning function.

Signature

declare function layer(spawn: (id: number) => any): Layer<WorkerPlatform | Spawner>;

Provides the Node WorkerPlatform for worker_threads workers and child process workers, wiring messages, errors, and exits into Effect workers and terminating the worker if graceful shutdown times out.

Signature

declare const layerPlatform: Layer.Layer<Worker.WorkerPlatform>;