From ec91f8e5eef7c3f39ac4cece443dd59129b9a608 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Wed, 12 Nov 2025 03:19:42 +0100 Subject: [PATCH] Fix --- packages/example/src/routes/result.tsx | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/example/src/routes/result.tsx b/packages/example/src/routes/result.tsx index 43ff71e..8dc31b3 100644 --- a/packages/example/src/routes/result.tsx +++ b/packages/example/src/routes/result.tsx @@ -19,14 +19,14 @@ const ResultView = Component.makeUntraced("Result")(function*() { Effect.andThen(response => response.json), Effect.andThen(Schema.decodeUnknown(Post)), Effect.tap(Effect.sleep("250 millis")), - Result.forkEffect, + Result.forkEffectSubscriptionRef, )) const [result] = yield* Subscribable.useSubscribables([resultSubscribable]) yield* Component.useOnMount(() => ErrorObserver.ErrorObserver().pipe( Effect.andThen(observer => observer.subscribe), Effect.andThen(Stream.fromQueue), - Stream.unwrap, + Stream.unwrapScoped, Stream.runForEach(flow( Cause.failures, Chunk.findFirst(e => e._tag === "RequestError" || e._tag === "ResponseError"),