Combine-AnyPublisher
- Publisher 中的 Output 和 Failure 两个关联类型如果进行多次嵌套会让类型变得非常复杂，难以阅读，而实际开发中往往需要经过多次的操作才能得到合适的 Publisher。
- 对于 Subscriber 来说，只需要关心 Publisher 的 Output 和 Failure 两个类型就能顺利订阅，它并不需要具体知道这个 Publisher 是如何得到、如何嵌套的。
- 为了对复杂类型的 Publisher 进行类型抹消，Combine 提供了
eraseToAnyPublisher()方法将复杂的 Publisher 转化为对应的通用类型AnyPublisher。 - 案例
import Combine
// p1类型: Publishers.FlatMap<Publishers.Sequence<[Int], Never>, Publishers.Sequence<[[Int]], Never>>
let p1 = [[1, 2, 3], [4, 5, 6]]
.publisher
.flatMap { $0.publisher }
// p2类型: Publishers.Map<Publishers.FlatMap<Publishers.Sequence<[Int], Never>, Publishers.Sequence<[[Int]], Never>>, Int>
let p2 = p1.map { $0 * 2 }
// p3类型: AnyPublisher<Int, Never>
let p3 = p2.eraseToAnyPublisher()- 使用
eraseToAnyPublisher进行类型抹消后的 Publisher 变得简单明了易于理解，这在实际开发中经常使用。
import UIKit
import Combine
class DataPublisher {
private var dataPublisher: AnyPublisher<URLSession.DataTaskPublisher.Output, URLSession.DataTaskPublisher.Failure>
var cancellable: AnyCancellable?
init(){
let url = URL(string: "http://v.juhe.cn/toutiao/index?type=top")
let request = URLRequest(url: url!)
let session = URLSession.shared
// 1. 创建发布者
self.dataPublisher = session.dataTaskPublisher(for: request).eraseToAnyPublisher()
// 2. 订阅
cancellable = dataPublisher
.receive(on: DispatchQueue.main).sink(receiveCompletion: {_ in
}) { (data: Data, response: URLResponse) in
}
}
}- Combine 中还提供了类似的类型抹消操作，如
eraseToAnySubscriber和eraseToAnySubject。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读