From 5cbbdb774648442e05f9fefa186dfb838307b18a Mon Sep 17 00:00:00 2001 From: Tim Date: Sun, 2 Feb 2025 15:00:35 +1300 Subject: [PATCH] fix worker tests --- packages/rpc/test/RpcWorker.test.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/packages/rpc/test/RpcWorker.test.ts b/packages/rpc/test/RpcWorker.test.ts index e8447d1b5c..e22e3bb831 100644 --- a/packages/rpc/test/RpcWorker.test.ts +++ b/packages/rpc/test/RpcWorker.test.ts @@ -2,6 +2,7 @@ import "@vitest/web-worker" import * as BrowserWorker from "@effect/platform-browser/BrowserWorker" +import { RpcServer } from "@effect/rpc" import * as RpcClient from "@effect/rpc/RpcClient" import { describe } from "@effect/vitest" import { Layer } from "effect" @@ -11,7 +12,10 @@ import { UsersClient } from "./fixtures/schemas.js" describe("RpcWorker", () => { const WorkerClient = UsersClient.layer.pipe( Layer.provide(RpcClient.layerProtocolWorker({ size: 1 })), - Layer.provide(BrowserWorker.layerPlatform(() => new Worker(new URL("./fixtures/worker.ts", import.meta.url)))) + Layer.provide(BrowserWorker.layerPlatform(() => new Worker(new URL("./fixtures/worker.ts", import.meta.url)))), + Layer.merge(Layer.succeed(RpcServer.Protocol, { + supportsAck: true + } as any)) ) e2eSuite("e2e worker", WorkerClient) })