上一篇解说了 Combine 中的两大概念：Publisher 和 Subscriber 以及其根本运用。这一篇首要解说一下，当 Combine 流中产生过错，咱们应该怎么处理。
过错首要是分为两大类，一种是过错类型不匹配，一种则是上下游操作产生反常。
过错类型不匹配
假设，咱们要完成一个加载网络图片的一个需求。
首要，定义一个 RequestError 的枚举，用来表示请求过程中产生的过错：
enum RequestError: Error {
case sessionError(error: Error)
}
接着，声明两个实例对象：
private let imageURLPublisher = PassthroughSubject<URL, RequestError>() // 图片加载请求发布者
private var cancel: AnyCancellable?
然后，将数据与接受者进行绑定：
cancel = imageURLPublisher.flatMap { requestURL in
return URLSession.shared.dataTaskPublisher(for: requestURL)
}.sink { error in
print(error)
} receiveValue: { result in
let image = UIImage(data: result.data)
print(image)
}
但此时你会发现编译报错:
DataTaskPublisher 的过错类型为 URLError， 与 RequestError 类型是不一致。
DataTaskPublisher 源码：
public struct DataTaskPublisher : Publisher, Sendable {
public typealias Output = (data: Data, response: URLResponse)
public typealias Failure = URLError
public let request: URLRequest
public let session: URLSession
public init(request: URLRequest, session: URLSession)
public func receive<S>(subscriber: S) where S : Subscriber, S.Failure == URLError, S.Input == (data: Data, response: URLResponse)
}
咱们用 mapError 将过错类型进行一下转换就能够了:
cancel = imageURLPublisher.flatMap { requestURL in
return URLSession.shared.dataTaskPublisher(for: requestURL)
.mapError { error -> RequestError in
return RequestError.sessionError(error: error)
}
}.sink { error in
print(error)
} receiveValue: { result in
let image = UIImage(data: result.data)
print(image)
}
最后，便是在 touchesBegan 中触发图片加载：
override func touchesBegan(_ touches: Set<UITouch>, with event: UIEvent?) {
imageURLPublisher.send(URL(string: "https://httpbin.org/image/jpeg")!)
// RequestError.sessionError(error: Error Domain=NSURLErrorDomain Code=-1200 "An SSL error has occurred and a secure connection to the server cannot be made."
imageURLPublisher.send(URL(string: "https://unknown.url/image")!) // 这个会走 Error 的分支，打印上述过错信息
}
运行一下项目，点击一下屏幕就能够看到控制台对 image 的打印了。
上下游操作产生反常
当操作流产生反常的时分，比如：网络加载失利、JSON 字符串解析失利等。咱们能够通过下述的几个函数来进行过错处理。
assertNoFailure(_:file:line:)
当上游发布者产生过错时，抛出反常。首要用在测验版别中，用来提前发现某些场景下的过错。
代码示例：
public enum SubjectError: Error {
case genericSubjectError
}
let subject = PassthroughSubject<String, Error>()
cancel = subject
.assertNoFailure()
.sink(receiveCompletion: { print ("completion: \($0)") },
receiveValue: { print ("value: \($0).") }
)
subject.send("数据")
subject.send(completion: Subscribers.Completion<Error>.failure(SubjectError.genericSubjectError))
当 subject 第一次调用 send 会发送一个 “数据” 的字符串，第2次调用则是发送了一个 SubjectError 类型的过错。
因为 subject 调用了 assertNoFailure() 函数，所以，当第2次调用 send 的时分会直接抛出反常。
catch 和 replaceError
当在 Combine 流中产生过错时，如果你想捕获过错而且忽略它，能够运用 catch 操作符。该操作符能够在产生过错的时分，答应你回来一个默认值。比如下面这两种场景：
cancel = imageURLPublisher.flatMap { requestURL in
...与上文一致
}.map({ result -> UIImage? in
return UIImage(data: result.data)
}).catch({ error -> Just<UIImage?> in
return Just(notFoundImage)
}).sink(receiveValue: { image in
print(image)
})
当 Combine 产生过错的时分，也能够运用 replaceError(with:) 来进行处理。它的作用是将过错替换成供给的值。当你想要通过发送单个替换元素来处理过错并结束流时对错常有用的。
它和 catch 的区别便是：彻底忽略过错，不会去关怀过错信息。而 catch 咱们是能够根据过错信息来进行逻辑处理的。它的运用便是将上述的 catch 替换为 .replaceError(with: notFoundImage) 即可。
