Publisher和Subscriber通信机制剖析（第一部分）

2023-12-11 10:29:48

Publisher和Subscriber概述

在Reactive Programming中，数据流的传输和处理需要通过Publisher（发布者）和Subscriber（订阅者）来完成。Publisher负责产生数据并将其发送给Subscriber，而Subscriber则负责接收和处理这些数据。它们之间的通信遵循Observer设计模式，保证了数据的单向流动。

Publisher

Publisher是Reactive Programming中的数据源，负责创建和发送数据序列。它可以是任何可以产生数据的事物，例如传感器、数据库或网络请求。Publisher提供了一个subscribe()方法，允许Subscriber订阅数据流。

Subscriber

Subscriber是Reactive Programming中的数据接收者，负责接收和处理Publisher发送的数据。它可以是任何可以处理数据的对象，例如用户界面、日志文件或另一个Publisher。Subscriber提供了一个onNext()方法，用于处理接收到的数据。

Combine框架中的Publisher

Combine框架提供了两个内置的Publisher：Just和Future。

Just

Just是一个简单的Publisher，它只发送一个值，然后完成。Just可以通过just()方法创建。

let publisher = Just("Hello, world!")

Future

Future是一个异步的Publisher，它在未来某个时间点发送一个值，然后完成。Future可以通过future()方法创建。

let future = Future {
  // Do something asynchronously
  return "Hello, world!"
}

使用Just和Future发送数据

可以使用subscribe()方法订阅Publisher并接收数据。

publisher.subscribe { value in
  // Process the value
}

也可以使用sink()方法订阅Publisher并接收数据。

publisher.sink { completion in
  switch completion {
  case .finished:
    // Publisher has completed sending data
  case .failure(let error):
    // Publisher has failed with an error
  }
}