Addressing Node.js issue with running TypeScript file
This platform cannot run Node.js because its
range.tsrange.ts file is in TypeScript format, and Node.js can only run .js.js files. What should we do?import { Worker } from "@effect/platform"
import { NodeRuntime, NodeWorker } from "@effect/platform-node"
import { Console, Context, Effect, Layer, Stream } from "effect"
import * as WT from "node:worker_threads"
interface MyWorkerPool {
readonly _: unique symbol
}
const Pool = Context.GenericTag<MyWorkerPool, Worker.WorkerPool<number, never, number>>("@app/MyWorkerPool")
const PoolLive = Worker.makePoolLayer(Pool, {
minSize: 0,
maxSize: 3,
timeToLive: 30000
}).pipe(
Layer.provide(NodeWorker.layer(() => new WT.Worker("./examples/worker/range.ts")))
)
Effect.gen(function*(_) {
const pool = yield* _(Pool)
yield* _(
Effect.all([
pool.execute(5).pipe(
Stream.runForEach((_) => Console.log("worker 1", _))
),
pool.execute(10).pipe(
Stream.runForEach((_) => Console.log("worker 2", _))
),
pool.execute(15).pipe(
Stream.runForEach((_) => Console.log("worker 3", _))
)
], { concurrency: "inherit" })
)
}).pipe(Effect.provide(PoolLive), NodeRuntime.runMain)import { Worker } from "@effect/platform"
import { NodeRuntime, NodeWorker } from "@effect/platform-node"
import { Console, Context, Effect, Layer, Stream } from "effect"
import * as WT from "node:worker_threads"
interface MyWorkerPool {
readonly _: unique symbol
}
const Pool = Context.GenericTag<MyWorkerPool, Worker.WorkerPool<number, never, number>>("@app/MyWorkerPool")
const PoolLive = Worker.makePoolLayer(Pool, {
minSize: 0,
maxSize: 3,
timeToLive: 30000
}).pipe(
Layer.provide(NodeWorker.layer(() => new WT.Worker("./examples/worker/range.ts")))
)
Effect.gen(function*(_) {
const pool = yield* _(Pool)
yield* _(
Effect.all([
pool.execute(5).pipe(
Stream.runForEach((_) => Console.log("worker 1", _))
),
pool.execute(10).pipe(
Stream.runForEach((_) => Console.log("worker 2", _))
),
pool.execute(15).pipe(
Stream.runForEach((_) => Console.log("worker 3", _))
)
], { concurrency: "inherit" })
)
}).pipe(Effect.provide(PoolLive), NodeRuntime.runMain)
