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)) ),