Thilawyn/reffuse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

0.1.11 #14

Merged
Thilawyn merged 318 commits from next into master 2025-05-19 14:01:41 +02:00
Conversation 0 Commits 318 Files Changed 17 +3 -3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 043e966e45 - Show all commits

6
packages/extension-query/src/ErrorHandler.ts
View File

@@ -4,7 +4,7 @@ import type { Mutable } from "effect/Types"
export interface ErrorHandler<E> { export interface ErrorHandler<E> {
readonly errors: Stream.Stream<Cause.Cause<E>> readonly errors: Stream.Stream<Cause.Cause<E>>
readonly handle: <A, SelfE extends E, R>(self: Effect.Effect<A, SelfE, R>) => Effect.Effect<A, Exclude<SelfE, E>, R> readonly handle: <A, SelfE, R>(self: Effect.Effect<A, SelfE, R>) => Effect.Effect<A, Exclude<SelfE, E>, R>
} }
export type Error<T> = T extends ErrorHandler<infer E> ? E : never export type Error<T> = T extends ErrorHandler<infer E> ? E : never
@@ -29,9 +29,9 @@ export const Service = <Self, E = never>() => (
const queue = yield* Queue.unbounded<Cause.Cause<E>>() const queue = yield* Queue.unbounded<Cause.Cause<E>>()
const errors = Stream.fromQueue(queue) const errors = Stream.fromQueue(queue)
const handle = <A, SelfE extends E, R>( const handle = <A, SelfE, R>(
self: Effect.Effect<A, SelfE, R> self: Effect.Effect<A, SelfE, R>
): Effect.Effect<A, Exclude<SelfE, E>, R> => f(self, ): Effect.Effect<A, Exclude<SelfE, E>, R> => f(self as unknown as Effect.Effect<A, E, R>,
(failure: E) => Queue.offer(queue, Cause.fail(failure)).pipe( (failure: E) => Queue.offer(queue, Cause.fail(failure)).pipe(
Effect.andThen(Effect.failCause(Cause.empty)) Effect.andThen(Effect.failCause(Cause.empty))
), ),