import { OperatorFunction } from 'rxjs';
import { catchError } from 'rxjs/operators';

export function convertError<T, NewError>(
  oldErrorType: { new (...args: never[]): unknown },
  newErrorType: { new (): NewError }
): OperatorFunction<T, T> {
  return catchError((error) => {
    if (error instanceof oldErrorType) {
      throw new newErrorType();
    }
    throw error;
  });
}