From 043e966e459b95e27f3f3345a4fcfd01d3e5d2eb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Sun, 23 Mar 2025 07:25:03 +0100 Subject: [PATCH] ErrorHandler work --- packages/extension-query/src/ErrorHandler.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/extension-query/src/ErrorHandler.ts b/packages/extension-query/src/ErrorHandler.ts index b777526..0437901 100644 --- a/packages/extension-query/src/ErrorHandler.ts +++ b/packages/extension-query/src/ErrorHandler.ts @@ -4,7 +4,7 @@ import type { Mutable } from "effect/Types" export interface ErrorHandler { readonly errors: Stream.Stream> - readonly handle: (self: Effect.Effect) => Effect.Effect, R> + readonly handle: (self: Effect.Effect) => Effect.Effect, R> } export type Error = T extends ErrorHandler ? E : never @@ -29,9 +29,9 @@ export const Service = () => ( const queue = yield* Queue.unbounded>() const errors = Stream.fromQueue(queue) - const handle = ( + const handle = ( self: Effect.Effect - ): Effect.Effect, R> => f(self, + ): Effect.Effect, R> => f(self as unknown as Effect.Effect, (failure: E) => Queue.offer(queue, Cause.fail(failure)).pipe( Effect.andThen(Effect.failCause(Cause.empty)) ),