美文网首页SwiftUI
Combine-AnyPublisher

Combine-AnyPublisher

作者: YungFan | 来源:发表于2020-05-05 15:41 被阅读0次
    • 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

    相关文章

      网友评论

        本文标题:Combine-AnyPublisher

        本文链接:https://www.haomeiwen.com/subject/ihbmghtx.html