概念

• Combine 中包括Publisher在内的一系列角色都使用协议来进行定义，这是 Swift 面向协议编程思想的具体体现。
• Publisher 随着时间推移向一个或多个Subscriber发布数据。
• Publisher 最主要的工作其实有两个
  • 被 Subscriber 订阅
  • 发布数据和数据

Publisher定义

public protocol Publisher {
    /// 发送的数据的类型
    associatedtype Output

    /// Publisher可能产生的错误类型，如果不会产生错误，则使用Never
    associatedtype Failure: Error

    /// 在调用Publisher的subscribe(_:)方法时方法内部会调用此方法去连接Subscriber
    func receive<S>(subscriber: S) where S: Subscriber, Self.Failure == S.Failure, Self.Output == S.Input
}

extension Publisher {
    /// 将指定的Subscriber连接到此Publisher
    /// 调用此方法连接而不是receive(subscriber:)
    public func subscribe<S>(_ subscriber: S) where S: Subscriber, Self.Failure == S.Failure, Self.Output == S.Input
}

解读

• Output及Failure定义了 Publisher 所发布的数据的类型和可能产生的错误类型。
• subscribe (_:)方法将 Subscriber 连接到 Publisher。 它规定: Publisher 的Output必须与 Subscriber 的Input类型匹配，Failure也是如此。

内置Publisher

• Just：只提供一个结果然后终止的 Publisher ，失败类型为<Never>。（★）
• Future：异步操作的 Publisher ，用一个闭包初始化，该闭包最终解析为单个输出数据或失败完成。（★）
• Empty： 一个从不发布任何数据的 Publisher ，并且可以选择立即完成。
• Fail：立即使用指定错误终止的 Publisher 。
• Optional：如果可选数据具有数据，则 Publisher 仅向每个 Subscriber 发布一次可选数据。
• Sequence：发布给定数据序列的 Publisher 。
• Deferred：在运行提供的闭包之前等待订阅的 Publisher ，以便为新的 Subscriber 创建 Publisher 。
• Record：允许记录一系列Input和Completion，供每个 Subscriber 回放。
• Publishers.Share：实现者为类的 Publisher ，其行为与其上游 Publisher 相同。
• Publishers.Multicast：多播 Publisher ，当有多个 Subscriber，但希望上游 Publisher 的每个数据仅调用一次receive（_ :)时使用。
• ObservableObject：与 SwiftUI 一起使用，符合ObservableObject协议的对象可以提供 Publisher 。（★）
• @Published：属性包装器，用来把一个属性数据转变为 Publisher 。（★）