t3-code-android-nightly/.repos/effect-smol/packages/platform/deno/test/RpcWorker.test.ts
Julius Marminge 6f9cea00ae
chore(refs): sync Effect and Alchemy references to 4.0.1 and beta.80 (#16170)
Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
2026-10-05 13:22:30 -07:00

21 lines
747 B
TypeScript

import * as DenoWorker from "@effect/platform-deno/DenoWorker"
import { describe } from "@effect/vitest"
import * as Layer from "effect/Layer"
import * as RpcClient from "effect/rpc/RpcClient"
import * as RpcServer from "effect/rpc/RpcServer"
import { e2eSuite, UsersClient } from "./fixtures/rpc-e2e.ts"
describe("RpcWorker", () => {
const WorkerClient = UsersClient.layer.pipe(
Layer.provide(RpcClient.layerProtocolWorker({ size: 1 })),
Layer.provide(
DenoWorker.layer(() => new Worker(new URL("./fixtures/rpc-worker.ts", import.meta.url), { type: "module" }))
),
Layer.merge(
Layer.succeed(RpcServer.Protocol)({
supportsAck: true
} as any)
)
)
e2eSuite("e2e worker", WorkerClient, false)
})