From 637aeaa04eaaf970b47ecc3426a832f216ddc30b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Mon, 1 Dec 2025 21:21:23 +0100 Subject: [PATCH] Fix --- packages/effect-fc/src/ErrorObserver.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/packages/effect-fc/src/ErrorObserver.ts b/packages/effect-fc/src/ErrorObserver.ts index 243242f..30f5424 100644 --- a/packages/effect-fc/src/ErrorObserver.ts +++ b/packages/effect-fc/src/ErrorObserver.ts @@ -18,7 +18,7 @@ extends Pipeable.Class() implements ErrorObserver { readonly subscribe: Effect.Effect>, never, Scope.Scope> constructor( - private readonly pubsub: PubSub.PubSub> + readonly pubsub: PubSub.PubSub> ) { super() this.subscribe = pubsub.subscribe @@ -36,8 +36,9 @@ class ErrorObserverSupervisorImpl extends Supervisor.AbstractSupervisor { } onEnd(_value: Exit.Exit): void { - if (Exit.isFailure(_value)) + if (Exit.isFailure(_value)) { Effect.runSync(PubSub.publish(this.pubsub, _value.cause as Cause.Cause)) + } } }