RxSwift中的Observables

2023-12-24 02:44:44

什么是Observables？

Observables是一种数据流，它可以发出值或错误。您可以订阅observables以在它们发出值或错误时收到通知。Observables非常强大，它们可以用于各种各样的任务，包括处理用户输入、网络请求和数据流。

如何创建Observables？

有许多方法可以创建observables。最常见的方法是使用create方法。create方法接受一个函数作为参数，该函数将被用来生成observables发出的值或错误。

let observable = Observable<Int>.create { observer in
  // 发出一些值
  observer.onNext(1)
  observer.onNext(2)
  observer.onNext(3)

  // 发出一个错误
  observer.onError(NSError(domain: "com.example.rxswift", code: 1, userInfo: nil))

  // 完成序列
  observer.onCompleted()

  // 返回一个disposable，以便稍后可以取消订阅
  return Disposables.create()
}

您还可以使用其他方法来创建observables，例如：

just方法：创建一个发出一个值的observable。
from方法：创建一个从数组或序列发出值的observable。
interval方法：创建一个每隔一定时间发出值的observable。
timer方法：创建一个在一定时间后发出值的observable。

如何订阅Observables？

要订阅observable，您可以使用subscribe方法。subscribe方法接受一个闭包作为参数，该闭包将在observable发出值或错误时被调用。

observable.subscribe { event in
  switch event {
  case .next(let value):
    // 处理收到的值
    print(value)
  case .error(let error):
    // 处理收到的错误
    print(error)
  case .completed:
    // 序列已完成
    print("序列已完成")
  }
}