Thilawyn/effect-fc
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix
All checks were successful
Lint / lint (push) Successful in 12s
Details

Browse Source
This commit is contained in:
Julien Valverdé
2025-12-01 21:21:23 +01:00
parent 5070c0706d
commit 637aeaa04e
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/effect-fc/src/ErrorObserver.ts
View File

@@ -18,7 +18,7 @@ extends Pipeable.Class() implements ErrorObserver<E> {
readonly subscribe: Effect.Effect<Queue.Dequeue<Cause.Cause<E>>, never, Scope.Scope> readonly subscribe: Effect.Effect<Queue.Dequeue<Cause.Cause<E>>, never, Scope.Scope>
constructor( constructor(
private readonly pubsub: PubSub.PubSub<Cause.Cause<E>> readonly pubsub: PubSub.PubSub<Cause.Cause<E>>
) { ) {
super() super()
this.subscribe = pubsub.subscribe this.subscribe = pubsub.subscribe
@@ -36,10 +36,11 @@ class ErrorObserverSupervisorImpl extends Supervisor.AbstractSupervisor<void> {
} }
onEnd<A, E>(_value: Exit.Exit<A, E>): void { onEnd<A, E>(_value: Exit.Exit<A, E>): void {
if (Exit.isFailure(_value)) if (Exit.isFailure(_value)) {
Effect.runSync(PubSub.publish(this.pubsub, _value.cause as Cause.Cause<never>)) Effect.runSync(PubSub.publish(this.pubsub, _value.cause as Cause.Cause<never>))
} }
} }
}
export const isErrorObserver = (u: unknown): u is ErrorObserver<unknown> => Predicate.hasProperty(u, TypeId) export const isErrorObserver = (u: unknown): u is ErrorObserver<unknown> => Predicate.hasProperty(u, TypeId)