Observableでエラーの型を明示的に扱いたい

ObservableE.swift

import RxSwift
import Result
protocol RxError: Error {
    init(anyError: Error)
}

typealias ObservableE<T, E: RxError> = Observable<Result<T, E>>

extension Observable {
    func asObservableE<Err: RxError>() -> ObservableE<E, Err> {
        return self
            .map(Result<E, Err>.success)
            .catchError { error -> ObservableE<E, Err> in
                return ObservableE.just(Result.failure(Err(anyError: error)))
            }
    }
}

SampleError.swift

struct InvalidJSONFormatError: Error {
    let data: Data
    let urlResponse: HTTPURLResponse
}

struct ValidationError: Error {
    let errors: [ValidationErrorInfo]
}

struct ValidationErrorInfo: Error {
    let code: Int
    let message: String
}

enum WebAPIError: RxError {
    case networkError
    case invalidJSONFormat(InvalidJSONFormatError)
    case validationError(ValidationError)
    case unknownError(Error)

    init(anyError: Error) {
        // できればas使わずにやりたかった
        switch anyError {
        case let error as InvalidJSONFormatError:
            self = .invalidJSONFormat(error)
        case let error as ValidationError:
            self = .validationError(error)
        case let error as NSError where error.code == 3840:
            self = .networkError
        default:
            self = .unknownError(anyError)
        }
    }
}

あとは ObservableE に対してがんばってオペレータを生やしたい。

要はこういうシグネチャのやつが欲しい。

func map<T2>(_ f: @escaping T -> T2) -> ObservableE<T2, E> 
func flatMap<T2>(_ f: @escaping T -> ObservableE<T2, E>) -> ObservableE<T2, E>