From 03474816ea61f6fe190b242bc36f3fc1069a2285 Mon Sep 17 00:00:00 2001 From: "opencode-agent[bot]" <219766164+opencode-agent[bot]@users.noreply.github.com> Date: Wed, 22 Jul 2026 09:40:31 -0500 Subject: [PATCH] test(core): stabilize wellknown event subscriptions (#38331) Co-authored-by: Aiden Cline --- packages/core/test/wellknown.test.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/core/test/wellknown.test.ts b/packages/core/test/wellknown.test.ts index 829f60ccd78..266e96f7546 100644 --- a/packages/core/test/wellknown.test.ts +++ b/packages/core/test/wellknown.test.ts @@ -69,7 +69,7 @@ serviceIt.live("persists sources in one KV value", () => const events = yield* EventV2.Service const changed = yield* events .subscribe(WellKnown.Event.Updated) - .pipe(Stream.take(1), Stream.runCollect, Effect.forkScoped) + .pipe(Stream.take(1), Stream.runCollect, Effect.forkScoped({ startImmediately: true })) const entry = yield* wellknown.add(`${server.url.origin}/`) expect(entry.origin).toBe(server.url.origin) @@ -108,7 +108,7 @@ serviceIt.live("refreshes changed manifests", () => const changed = yield* events .subscribe(WellKnown.Event.Updated) - .pipe(Stream.take(1), Stream.runCollect, Effect.forkScoped) + .pipe(Stream.take(1), Stream.runCollect, Effect.forkScoped({ startImmediately: true })) update() expect(yield* wellknown.refresh()).toBe(true) expect(yield* Fiber.join(changed)).toHaveLength(1)