A-A+

Combine-AnyPublisher

2020年05月11日 iOS原创文章 暂无评论
博客主机
  • 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 中还提供了类似的类型抹消操作,如eraseToAnySubscribereraseToAnySubject

  • Cocoa社区
  • 区块链社区

用户协议 · 隐私协议 · 权利声明 · 商务合作

京ICP备 1006519号 京ICP证 100954号

京公安网备 1101502037140号

京网文[2018]6281-491号

北京触控科技有限公司

版权所有@2020 Chikong Technologes,Inc

给我留言

Copyright © ios教程,苹果粉丝,苹果资讯,ios入门教程,ios学习,ios程序员,ios视频教程,ios粉丝网 保留所有权利.   Theme  Ality

用户登录