结合处理不同类型的发布者

Question

我是 Combine 的新手，一直被这个问题困扰。我有基本的注册表，如果一切正常，return 的空响应为 200 代码，如果表单有一些注册失败，则为 442。

这是可以处理空响应并且工作正常的代码

extension Route where ResultType: EmptyResult {
    func emptyResult() -> AnyPublisher<Void, APIError> {
        return URLSession.shared.dataTaskPublisher(for: urlRequest)
            .print("EMPTY RESULT")
            .tryMap { data, response in
                guard let httpResponse = response as? HTTPURLResponse else { throw APIError.nonHttpResponse(description: "Not http resp") }
                let statusCode = httpResponse.statusCode
                
                guard (200..<300).contains(statusCode) else { throw APIError.nonHttpResponse(description: "bad response")
                }
                    return Void()
            }.mapError { error in
                print("Error \(error)")
                return .network(description: error.localizedDescription)
            }
            .eraseToAnyPublisher()
    }
}

但是，我如何才能 return 使用其他类型的发布者？例如

struct CustomError: Decodable {
    let usernameError: String
    let emailError: String
}

我的网络电话：

    API.registration(name: name, email: email, password: password, schoolID: selectedSchool?.id ?? 0)
        .print("Registration")
        .receive(on: DispatchQueue.main)
        .sink(receiveCompletion: { (completion) in
            switch completion {
            case let .failure(error):
                print("ERROR \(error)")
            case .finished: break
            }
        }, receiveValue: { value in
            print(value)
        })
        .store(in: &disposables)

Answer 1

所以你有一个网络请求，如果请求成功，returns 一个 200 响应和一个空主体，而如果出现表单错误，它 returns 一个特定的状态代码和响应中的错误。

我建议将 Publisher 的 Output 类型保留为 Void，但是，如果出现格式错误，请解码错误并将其作为 Void 的一部分抛出=15=].

struct LoginError: Decodable {
    let usernameError: String
    let emailError: String
}

enum APIError: Error {
    case failureStatus(code: Int)
    case login(LoginError)
    case nonHttpResponse(description: String)
    case network(Error)
}

func emptyResult() -> AnyPublisher<Void, APIError> {
    return URLSession.shared.dataTaskPublisher(for: urlRequest)
        .print("EMPTY RESULT")
        .tryMap { data, response in
            guard let httpResponse = response as? HTTPURLResponse else { throw APIError.nonHttpResponse(description: "Not http response") }
            let statusCode = httpResponse.statusCode

            guard (200..<300).contains(statusCode) else {
                if statusCode == 442 {
                    let loginError = try JSONDecoder().decode(LoginError.self, from: data)
                    throw APIError.login(loginError)
                } else {
                    throw APIError.failureStatus(code: statusCode)
                }
            }
            return Void()
        }.mapError { error in
            switch error {
            case let apiError as APIError:
                return apiError
            default:
                return .network(error)
        }
    }
        .eraseToAnyPublisher()
}

然后您可以通过 switch 处理 sink 中的 error 来处理特定错误：

API.registration(name: name, email: email, password: password, schoolID: selectedSchool?.id ?? 0)
    .print("Registration")
    .receive(on: DispatchQueue.main)
    .sink(receiveCompletion: { (completion) in
        switch completion {
        case let .failure(error):
            switch error {
            case .login(let loginError):
                print("Login failed, \(loginError.emailError), \(loginError.usernameError)")
            default:
                print(error)
            }
        case .finished: break
        }
    }, receiveValue: { value in
        print(value)
    })
    .store(in: &disposables)

结合处理不同类型的发布者

Combine handle different type of publishers

networking

swift

combine