Swift Combine 网络受限时从备用 URL 请求数据从入门到精通十四

Combine 系列

Swift Combine 从入门到精通一
Swift Combine 发布者订阅者操作者从入门到精通二
Swift Combine 管道从入门到精通三
Swift Combine 发布者publisher的生命周期从入门到精通四
Swift Combine 操作符operations和Subjects发布者的生命周期从入门到精通五
Swift Combine 订阅者Subscriber的生命周期从入门到精通六
Swift 使用 Combine 进行开发从入门到精通七
Swift 使用 Combine 管道和线程进行开发从入门到精通八
Swift Combine 使用 sink, assign 创建一个订阅者从入门到精通九
Swift Combine 使用 dataTaskPublisher 发起网络请求从入门到精通十
Swift Combine 用 Future 来封装异步请求从入门到精通十一
Swift Combine 有序的异步操作从入门到精通十二
Swift Combine 使用 flatMap 和 catch错误处理从入门到精通十三

1. 使用 flatMap 和 catch 在不取消管道的情况下处理错误

目的： flatMap 操作符可以与 catch 一起使用，以持续处理新发布的值上的错误。

flatMap 是用于处理持续事件流中错误的操作符。

你提供一个闭包给 flatMap，该闭包可以获取所传入的值，并创建一个一次性的发布者，完成可能失败的工作。这方面的一个例子是从网络请求数据，然后将其解码。你可以引入一个 catch 操作符，以捕获任何错误并提供适当的值。

当你想要保持对上游发布者的更新时，这是一个完美的机制，因为它创建一次性的发布者或短管道，发送一个单一的值，然后完成每一个传入的值。所创建的一次性发布者的完成事件在 flatMap 中终止，并且不会传递给下游订阅者。

一个使用 dataTaskPublisher 的这样的例子:

let remoteDataPublisher = Just(self.testURL!)  // 1
    .flatMap { url in  // 2
        URLSession.shared.dataTaskPublisher(for: url)  // 3
        .tryMap { data, response -> Data in  // 4
            guard let httpResponse = response as? HTTPURLResponse,
                httpResponse.statusCode == 200 else {
                    throw TestFailureCondition.invalidServerResponse
            }
            return data
        }
        .decode(type: PostmanEchoTimeStampCheckResponse.self, decoder: JSONDecoder())  // 5
        .catch {_ in  // 6
            return Just(PostmanEchoTimeStampCheckResponse(valid: false))
        }
    }
    .eraseToAnyPublisher()

Just 以传入一个 URL 作为示例启动此发布者。
flatMap 以 URL 作为输入，闭包继续创建一次性发布者管道。
dataTaskPublisher 使用输入的 url 发出请求。
输出的结果（一个 (Data, URLResponse) 元组）流入 tryMap 以解析其他错误。
decode 尝试将返回的数据转换为本地定义的类型。
如果其中任何一个失败，catch 将把错误转换为一个默认的值。在这个例子中，是具有预设好 valid = false 属性的对象。

2. 网络受限时从备用 URL 请求数据

目的: 在 Apple 的 WWDC 2019 演示 Advances in Networking, Part 1 中，使用 tryCatch 和 tryMap 操作符提供了示例模式，以响应网络受到限制的特殊错误。

// Generalized Publisher for Adaptive URL Loading
func adaptiveLoader(regularURL: URL, lowDataURL: URL) -> AnyPublisher<Data, Error> {
    var request = URLRequest(url: regularURL)  // 1
    request.allowsConstrainedNetworkAccess = false  // 2
    return URLSession.shared.dataTaskPublisher(for: request)  // 3
        .tryCatch { error -> URLSession.DataTaskPublisher in  // 4
            guard error.networkUnavailableReason == .constrained else {
               throw error
            }
            return URLSession.shared.dataTaskPublisher(for: lowDataURL)  // 5
        .tryMap { data, response -> Data in
            guard let httpResponse = response as? HTTPUrlResponse,  // 6
                   httpResponse.statusCode == 200 else {
                       throw MyNetworkingError.invalidServerResponse
            }
            return data
}
.eraseToAnyPublisher()  // 7

在苹果的 WWDC 中的这个例子，提供了一个函数，接受两个 URL 作为参数 —— 一个主要的 URL 和一个备用的。它会返回一个发布者，该发布者将请求数据，并在网络受到限制时向备用 URL 请求数据。

request 变量是一个尝试请求数据的 URLRequest。
设置 request.allowsConstrainedNetworkAccess 将导致 dataTaskPublisher 在网络受限时返回错误。
调用 dataTaskPublisher 发起请求。
tryCatch 用于捕获当前的错误状态并检查特定错误（受限的网络）。
如果它发现错误，它会使用备用 URL 创建一个新的一次性发布者。
由此产生的发布者仍可能失败，tryMap 可以基于对应到错误条件的 HTTP 响应码来抛出错误，将此映射为失败。
eraseToAnyPublisher 可在操作符链上进行类型擦除，因此 adaptiveLoader 函数的返回类型为 AnyPublisher<Data, Error>。