# 4.1 Observable - 可监听序列

![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F84f20719d64aca9fd65e9211b44577e6db32546e.png?generation=1616819392696917\&alt=media)

## 所有的事物都是序列

之前我们提到，`Observable` 可以用于描述元素异步产生的序列。这样我们生活中许多事物都可以通过它来表示，例如：

* **`Observable<Double>` 温度**

  你可以将温度看作是一个序列，然后监测这个温度值，最后对这个值做出响应。例如：当室温高于 33 度时，打开空调降温。

  ![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F18c51c05a934714054994bd816a0566ea76e66bc.png?generation=1616819392978552\&alt=media)
* **`Observable<OnePieceEpisode>` 《海贼王》动漫**

  你也可以把《海贼王》的动漫看作是一个序列。然后当《海贼王》更新一集时，我们就立即观看这一集。

  ![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F9a0146a6b85ee6e415ba53ae91989b1937278161.png?generation=1616819392778489\&alt=media)
* **`Observable<JSON>` JSON**

  你可以把网络请求的返回的 JSON 看作是一个序列。然后当取到 JSON 时，将它打印出来。

  ![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F009ef302d9b2bf17e2d6f6b897040ceab814ef20.png?generation=1616819393020237\&alt=media)
* **`Observable<Void>` 任务回调**

  你可以把任务回调看作是一个序列。当任务结束后，提示用户任务已完成。

  ![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2Fd5c79574fa0b94601a7fe6bc750495c6e49711db.png?generation=1616819392722527\&alt=media)

## 如何创建序列

现在我们已经可以把生活中的许多事物看作是一个序列了。那么我们要怎么创建这些序列呢？

实际上，框架已经帮我们创建好了许多常用的序列。例如：`button`的点击，`textField`的当前文本，`switch`的开关状态，`slider`的当前数值等等。

另外，有一些自定义的序列是需要我们自己创建的。这里介绍一下创建序列最基本的方法，例如，我们创建一个 `[0, 1, ... 8, 9]` 的序列：

![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F84f20719d64aca9fd65e9211b44577e6db32546e.png?generation=1616819392810821\&alt=media)

```swift
let numbers: Observable<Int> = Observable.create { observer -> Disposable in

    observer.onNext(0)
    observer.onNext(1)
    observer.onNext(2)
    observer.onNext(3)
    observer.onNext(4)
    observer.onNext(5)
    observer.onNext(6)
    observer.onNext(7)
    observer.onNext(8)
    observer.onNext(9)
    observer.onCompleted()

    return Disposables.create()
}
```

创建序列最直接的方法就是调用 `Observable.create`，然后在构建函数里面描述元素的产生过程。 `observer.onNext(0)` 就代表产生了一个元素，他的值是 `0`。后面又产生了 9 个元素分别是 `1, 2, ... 8, 9` 。最后，用 `observer.onCompleted()` 表示元素已经全部产生，没有更多元素了。

你可以用这种方式来封装功能组件，例如，闭包回调：

![1](https://4217506537-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-MWj545abP2yK86-qksJ%2Fsync%2F009ef302d9b2bf17e2d6f6b897040ceab814ef20.png?generation=1616819392931729\&alt=media)

```swift
typealias JSON = Any

let json: Observable<JSON> = Observable.create { (observer) -> Disposable in

    let task = URLSession.shared.dataTask(with: ...) { data, _, error in

        guard error == nil else {
            observer.onError(error!)
            return
        }

        guard let data = data,
            let jsonObject = try? JSONSerialization.jsonObject(with: data, options: .mutableLeaves)
            else {
            observer.onError(DataError.cantParseJSON)
            return
        }

        observer.onNext(jsonObject)
        observer.onCompleted()
    }

    task.resume()

    return Disposables.create { task.cancel() }
}
```

在闭包回调中，如果任务失败，就调用 `observer.onError(error!)`。如果获取到目标元素，就调用 `observer.onNext(jsonObject)`。由于我们的这个序列只有一个元素，所以在成功获取到元素后，就直接调用 `observer.onCompleted()` 来表示任务结束。最后 `Disposables.create { task.cancel() }` 说明如果数据绑定被清除（订阅被取消）的话，就取消网络请求。

这样一来我们就将传统的闭包回调转换成序列了。然后可以用 `subscribe` 方法来响应这个请求的结果：

```swift
json
    .subscribe(onNext: { json in
        print("取得 json 成功: \(json)")
    }, onError: { error in
        print("取得 json 失败 Error: \(error.localizedDescription)")
    }, onCompleted: {
        print("取得 json 任务成功完成")
    })
    .disposed(by: disposeBag)
```

这里`subscribe`后面的`onNext`,`onError`, `onCompleted` 分别响应我们创建 json 时，构建函数里面的`onNext`,`onError`, `onCompleted` 事件。我们称这些事件为 **Event**:

## Event - 事件

```swift
public enum Event<Element> {
    case next(Element)
    case error(Swift.Error)
    case completed
}
```

* next - 序列产生了一个新的元素
* error - 创建序列时产生了一个错误，导致序列终止
* completed - 序列的所有元素都已经成功产生，整个序列已经完成

你可以合理的利用这些 `Event` 来实现业务逻辑。

## 决策树

现在我们知道如何用最基本的方法创建序列。你还可参考 [决策树](https://3440217568.gitbook.io/rxswift/decision_tree) 来选择其他的方式创建序列。

## 特征序列

我们都知道 **Swift** 是一个强类型语言，而强类型语言相对于弱类型语言的一个优点是更加严谨。我们可以通过类型来判断出，实例有哪些特征。同样的在 **RxSwift** 里面 `Observable` 也存在一些特征序列，这些特征序列可以帮助我们更准确的描述序列。并且它们还可以给我们提供语法糖，让我们能够用更加优雅的方式书写代码，他们分别是：

* [Single](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/single)
* [Completable](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/completable)
* [Maybe](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/maybe)
* [Driver](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/driver)
* [Signal](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/signal)
* [ControlEvent](https://3440217568.gitbook.io/rxswift/rxswift_core/observable/control_event)

*ℹ️ 提示：由于**可被观察的序列（Observable）**&#x540D;字过长，很多时候会增加阅读难度，所以笔者在必要时会将它简写为：**序列**。*