@effect/platform-node - npm Package Compare versions

Comparing version 0.27.5 to 0.27.6

package.json

		{
		"name": "@effect/platform-node",
		"version": "0.27.5",
		"version": "0.27.6",
		"description": "Unified interfaces for common platform-specific services",
		@@ -49,3 +49,3 @@ "main": "dist/effect-platform-node.cjs.js",
		"mime": "^3.0.0",
		"@effect/platform": "^0.26.3"
		"@effect/platform": "^0.26.4"
		},
		@@ -52,0 +52,0 @@ "files": [

src/internal/worker.ts

		@@ -24,3 +24,2 @@ import * as Worker from "@effect/platform/Worker"
		))
		const fiberId = yield* _(Effect.fiberId)
		const queue = yield* _(Queue.unbounded<Worker.BackingWorker.Message<O>>())
		@@ -43,5 +42,4 @@ yield* _(Effect.addFinalizer(() => Queue.shutdown(queue)))
		}),
		Effect.forkDaemon
		Effect.forkScoped
		)
		yield* _(Effect.addFinalizer(() => fiber.interruptAsFork(fiberId)))
		const join = Fiber.join(fiber)
		@@ -48,0 +46,0 @@ const send = (message: I, transfers?: ReadonlyArray<unknown>) =>

src/internal/workerRunner.ts

		@@ -53,2 +53,2 @@ import { WorkerError } from "@effect/platform/WorkerError"
		options?: Runner.Runner.Options<O>
		): Effect.Effect<Scope.Scope \| R, WorkerError, void> => Effect.provide(Runner.make(process, options), layer)
		): Effect.Effect<Scope.Scope \| R, WorkerError, never> => Effect.provide(Runner.make(process, options), layer)

Worker/dist/effect-platform-node-Worker.cjs.dev.js

		@@ -49,3 +49,2 @@ 'use strict';
		})));
		const fiberId = yield* _(Effect__namespace.fiberId);
		const queue = yield* _(Queue__namespace.unbounded());
		@@ -66,4 +65,3 @@ yield* _(Effect__namespace.addFinalizer(() => Queue__namespace.shutdown(queue)));
		});
		}), Effect__namespace.forkDaemon);
		yield* _(Effect__namespace.addFinalizer(() => fiber.interruptAsFork(fiberId)));
		}), Effect__namespace.forkScoped);
		const join = Fiber__namespace.join(fiber);
		@@ -70,0 +68,0 @@ const send = (message, transfers) => Effect__namespace.sync(() => worker.postMessage([0, message], transfers));

Worker/dist/effect-platform-node-Worker.cjs.prod.js

		@@ -49,3 +49,2 @@ 'use strict';
		})));
		const fiberId = yield* _(Effect__namespace.fiberId);
		const queue = yield* _(Queue__namespace.unbounded());
		@@ -66,4 +65,3 @@ yield* _(Effect__namespace.addFinalizer(() => Queue__namespace.shutdown(queue)));
		});
		}), Effect__namespace.forkDaemon);
		yield* _(Effect__namespace.addFinalizer(() => fiber.interruptAsFork(fiberId)));
		}), Effect__namespace.forkScoped);
		const join = Fiber__namespace.join(fiber);
		@@ -70,0 +68,0 @@ const send = (message, transfers) => Effect__namespace.sync(() => worker.postMessage([0, message], transfers));

Worker/dist/effect-platform-node-Worker.esm.js

		@@ -22,3 +22,2 @@ import * as Worker from '@effect/platform/Worker';
		})));
		const fiberId = yield* _(Effect.fiberId);
		const queue = yield* _(Queue.unbounded());
		@@ -39,4 +38,3 @@ yield* _(Effect.addFinalizer(() => Queue.shutdown(queue)));
		});
		}), Effect.forkDaemon);
		yield* _(Effect.addFinalizer(() => fiber.interruptAsFork(fiberId)));
		}), Effect.forkScoped);
		const join = Fiber.join(fiber);
		@@ -43,0 +41,0 @@ const send = (message, transfers) => Effect.sync(() => worker.postMessage([0, message], transfers));

New alerts