【发布时间】:2021-02-18 19:04:56
【问题描述】:
我的 api .post 方法有这个通用实现:
func post<T: Decodable>(endpoint: Endpoint, parameters: Parameters, responseType: T.Type) -> AnyPublisher<T, Error> {
sessionManager.request(self.baseUrl + endpoint.path, method: .post, parameters: parameters)
.publishDecodable(type: responseType)
.value()
.mapError(ServiceError.init(error: ))
.eraseToAnyPublisher()
}
它正在工作,我认为这就是它在 SwiftUI/Combine 中应该有的样子。我的问题是,当我得到其他状态码然后是 2xx 时,我希望能够解析响应。我找到了this answer 和this article 来了解如何做到这一点。
在这个帮助下,我能够将我的代码更改为:
func post<T: Decodable>(endpoint: Endpoint, parameters: Parameters, responseType: T.Type, completionHandler: @escaping (Result<T, ErrorResponse>) -> Void) {
sessionManager.upload(multipartFormData: multipartFormData, to: self.baseUrl + endpoint.path, method: .post, headers: headers)
.validate(statusCode: 200..<300)
.responseTwoDecodable(of: responseType, completionHandler: completionHandler)
}
更多信息在这里是我的TwoDecodableResponseSerializer(在这两个链接的帮助下创建):
final class TwoDecodableResponseSerializer<T: Decodable>: ResponseSerializer {
lazy var decoder: JSONDecoder = {
let decoder = JSONDecoder()
decoder.dateDecodingStrategy = .iso8601
return decoder
}()
private lazy var successSerializer = DecodableResponseSerializer<T>(decoder: decoder)
private lazy var errorSerializer = DecodableResponseSerializer<ErrorResponse>(decoder: decoder)
public func serialize(request: URLRequest?, response: HTTPURLResponse?, data: Data?, error: Error?) throws -> Result<T, ErrorResponse> {
guard let response = response else { return .failure(ErrorResponse()) }
do {
if response.statusCode < 200 || response.statusCode >= 300 {
let result = try errorSerializer.serialize(request: request, response: response, data: data, error: nil)
return .failure(result)
} else {
let result = try successSerializer.serialize(request: request, response: response, data: data, error: nil)
return .success(result)
}
} catch(let err) {
return .failure(ErrorResponse())
}
}
}
extension DataRequest {
@discardableResult func responseTwoDecodable<T: Decodable>(queue: DispatchQueue = DispatchQueue.global(qos: .userInitiated), of t: T.Type, completionHandler: @escaping (Result<T, ErrorResponse>) -> Void) -> Self {
return response(queue: .main, responseSerializer: TwoDecodableResponseSerializer<T>()) { response in
switch response.result {
case .success(let result):
completionHandler(result)
case .failure(let error):
completionHandler(.failure(ErrorResponse()))
}
}
}
}
和错误响应:
class ErrorResponse: Error, Decodable {
var error: Int = 0
enum CodingKeys: String, CodingKey {
case error = "error"
}
}
它正在工作。这很好,但我想要更多的反应/组合代码。没有关闭。是否可以?你会怎么做呢?
感谢您的帮助
【问题讨论】:
标签: swift swiftui alamofire reactive-programming combine