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)) + } } }