响应式异步编程的抽象和特点：
异步操作在合适的时机发布事件，这些事件带有数据，使用一个或多个操作来处理这些事件以及内部的数据。在末端，使用一个订阅者来 “消化” 这个事件和数据，并进一步驱动程序的其他部分(比如 UI 界面) 的运行。上面这些对于事件和数据的操作，以及末端的订阅，都是在事件发生之前完成的。一开始我们就将这些设定好，之后它可以以预设的方式响应源源不断发生的事件流。
Combine 中最重要的角色有三种：
- 负责发布事件的 Publisher，
- 负责订阅事件的 Subscriber，
- 负责转换事件和数据的 Operator。
Publisher
public protocol Publisher {
associatedtype Output
associatedtype Failure : Error
func receive<S>(subscriber: S) where
S : Subscriber,
Self.Failure == S.Failure,
Self.Output == S.Input
}
Publisher 最主要的工作其实有两个：
- 发布新的事件及其数据，
- 准备好被Subscriber 订阅。
Publisher 协议包括两个关联类型 (associatedtype) 以及一个 receive 方法:
- Output 定义了某个 Publisher 所发布的值的类型，
- Failure 则定义可能产生的错误的类型。
Publisher 可以发布三种事件：
- 类型为 Output 的新值：这代表事件流中出现了新的值。
- 类型为 Failure 的错误：这代表事件流中发生了问题，事件流到此终止。
- 完成事件：表示事件流中所有的元素都已经发布结束，事件流到此终止。
后两种事件在 Combine 中 则使用Subscribers.Completion 来描述，它是一个含有两个成员的 enum，其中成员类型为 .failure(Failure) 以及 .finished。
Operator
使用上游 Publisher 所发布的数据作为输入，以此产生的新的数据，然后自身成为新的 Publisher，并将这些新的数据作为输出，发布给下游。
Subscriber
public protocol Subscriber {
associatedtype Input
associatedtype Failure : Error
func receive(subscription: Subscription)
func receive(_ input: Self.Input) -> Subscribers.Demand
func receive(completion: Subscribers.Completion<Self.Failure>)
}
Subscriber 也是一个抽象的协议，它定义了某个类型想要成为订阅者角色时所需要满足的条件：定义中 Input 和 Failure 分别表示了订阅者能够接受的事件流数据类型和错误类型。想要订阅某个 Publisher，Subscriber 中的这两个类型必须与 Publisher 的 Output 和 Failure 相同。
- sink 将响应函数式的 Publisher 链式代码，终结并桥接到基于闭包的指令式世界中来。
- assign 接受一个 class 对象以及对象类型上的某个键路径 (key path)。每当 output 事件到来时，其中包含的值就将被设置到对应的属性上去
Subject
public protocol Subject : AnyObject, Publisher {
func send(_ value: Self.Output)
func send(completion: Subscribers.Completion<Self.Failure>)
}
Subject 暴露了两个 send 方法，外部调用者可以通过这两个方法来主动地发布 output 值、failure 事件或 finished 事件。
Combine 内置提供了两种常用的 Subject 类型，分别是 PassthroughSubject和 CurrentValueSubject。
1.PassthroughSubject 简单地将 send 接收到的事件转发给下游的其他 Publisher 或 Subscriber
- CurrentValueSubject 则会包装和持有一个值，并在设置该值时发送事件并保留新的值。在订阅发生的瞬间，CurrentValueSubject 会把当前保存的值发送给订阅者。
Scheduler
如果说 Publisher 决定了发布怎样的 (what) 事件流的话，Scheduler 所要解决的就是两个问题：在什么地方 (where)，以及在什么时候 (when) 来发布事件和执行代码。
receive(on:options:)，delay(for:scheduler:) 和 debounce(for:scheduler:) 所接受的参数包括一个 Scheduler 实例。它们负责更改时间或者线程相关的内容，是调用机制的管理者。
