Reusable Partial Error Handling

what would be the recommended approach to reuse error handling ?

Say I have multiple pipelines yielding Effect<SomeOutput, Error1 | Error2 | Error3, R>, and I would like to die on Error2 and let the rest of the pipeline take care of the remaining errors.

I tried

class Error1 {
 _tag = 'Error1'
}
class Error2 {
 _tag = 'Error2'
}
class Error3 {
 _tag = 'Error3'
}

// this was my hope to capture any Error channel with at least Error2
const DieOnError2 = <A, E extends Error2, R>(
  effect: Ef.Effect<A, E, R>
) => {
  return effect.pipe(
    Effect.catchTag("Error2", (defect) => Effect.die(defect))
  );
};


// pipeline1 is Effect<number, Error1 | Error2, never>
const pipeline1 = 
// Type 'Error1 | Error2' is not assignable to type 'Error2'
someComputation.pipe(DieOnError2)

// pipeline2 is Effect<number, Error3 | Error2, never>
const pipeline2 = 
// Type 'Error3 | Error2' is not assignable to type 'Error2'
anotherComputation.pipe(DieOnError2)

class Error1 {
 _tag = 'Error1'
}
class Error2 {
 _tag = 'Error2'
}
class Error3 {
 _tag = 'Error3'
}

// this was my hope to capture any Error channel with at least Error2
const DieOnError2 = <A, E extends Error2, R>(
  effect: Ef.Effect<A, E, R>
) => {
  return effect.pipe(
    Effect.catchTag("Error2", (defect) => Effect.die(defect))
  );
};


// pipeline1 is Effect<number, Error1 | Error2, never>
const pipeline1 = 
// Type 'Error1 | Error2' is not assignable to type 'Error2'
someComputation.pipe(DieOnError2)

// pipeline2 is Effect<number, Error3 | Error2, never>
const pipeline2 = 
// Type 'Error3 | Error2' is not assignable to type 'Error2'
anotherComputation.pipe(DieOnError2)

however I get type error as DieOnError2 does not have all error possible in E ?

what would be the recommendation to build "building blocks" with partial information. I have big pipelines that can bubbles up 5 to 10 distinct errors. some will be discarded, other will be sent to telemetry and some needs to send back to the end user and I am trying to find a way to reuse the error handling

class Error1 {
 _tag = 'Error1'
}
class Error2 {
 _tag = 'Error2'
}
class Error3 {
 _tag = 'Error3'
}

// this was my hope to capture any Error channel with at least Error2
const DieOnError2 = <A, E extends Error2, R>(
  effect: Ef.Effect<A, E, R>
) => {
  return effect.pipe(
    Effect.catchTag("Error2", (defect) => Effect.die(defect))
  );
};


// pipeline1 is Effect<number, Error1 | Error2, never>
const pipeline1 = 
// Type 'Error1 | Error2' is not assignable to type 'Error2'
someComputation.pipe(DieOnError2)

// pipeline2 is Effect<number, Error3 | Error2, never>
const pipeline2 = 
// Type 'Error3 | Error2' is not assignable to type 'Error2'
anotherComputation.pipe(DieOnError2)

class Error1 {
 _tag = 'Error1'
}
class Error2 {
 _tag = 'Error2'
}
class Error3 {
 _tag = 'Error3'
}

// this was my hope to capture any Error channel with at least Error2
const DieOnError2 = <A, E extends Error2, R>(
  effect: Ef.Effect<A, E, R>
) => {
  return effect.pipe(
    Effect.catchTag("Error2", (defect) => Effect.die(defect))
  );
};


// pipeline1 is Effect<number, Error1 | Error2, never>
const pipeline1 = 
// Type 'Error1 | Error2' is not assignable to type 'Error2'
someComputation.pipe(DieOnError2)

// pipeline2 is Effect<number, Error3 | Error2, never>
const pipeline2 = 
// Type 'Error3 | Error2' is not assignable to type 'Error2'
anotherComputation.pipe(DieOnError2)

Reusable Partial Error Handling

Similar Threads

Reusable Partial Error Handling

Similar Threads

Similar Threads

Similar Threads