• Single
    • 如何创建 Single

    Single

    Single 是 Observable 的另外一个版本。不像 Observable 可以发出多个元素，它要么只能发出一个元素，要么产生一个 error 事件。

    • 发出一个元素，或一个 error 事件
    • 不会共享状态变化

    一个比较常见的例子就是执行 HTTP 请求，然后返回一个应答或错误。不过你也可以用 Single 来描述任何只有一个元素的序列。

    如何创建 Single

    创建 Single 和创建 Observable 非常相似：

    1. func getRepo(_ repo: String) -> Single<[String: Any]> {
    3.     return Single<[String: Any]>.create { single in
    4.         let url = URL(string: "https://api.github.com/repos/\(repo)")!
    5.         let task = URLSession.shared.dataTask(with: url) {
    6.             data, _, error in
    8.             if let error = error {
    9.                 single(.error(error))
    10.                 return
    11.             }
    13.             guard let data = data,
    14.                   let json = try? JSONSerialization.jsonObject(with: data, options: .mutableLeaves),
    15.                   let result = json as? [String: Any] else {
    16.                 single(.error(DataError.cantParseJSON))
    17.                 return
    18.             }
    20.             single(.success(result))
    21.         }
    23.         task.resume()
    25.         return Disposables.create { task.cancel() }
    26.     }
    27. }

    之后，你可以这样使用 Single：

    1. getRepo("ReactiveX/RxSwift")
    2.     .subscribe(onSuccess: { json in
    3.         print("JSON: ", json)
    4.     }, onError: { error in
    5.         print("Error: ", error)
    6.     })
    7.     .disposed(by: disposeBag)

    订阅提供一个 SingleEvent 的枚举：

    1. public enum SingleEvent<Element> {
    2.     case success(Element)
    3.     case error(Swift.Error)
    4. }
    • success - 产生一个单独的元素
    • error - 产生一个错误

    你同样可以对 Observable 调用 .asSingle() 方法，将它转换为 Single。