开始之前, 先建立一个全局函数:

public func example(of description: String, action: () -> Void) {
    print("\n--- Example of:", description, "---")
    action() 
}

这个函数在下面的例子中都会用到.

下面来看看到底什么是 Observable.

什么是 Observable

在许多例子里, 有讲到 Observable, Observable 序列, 序列, 甚至还有些地方说stream(流), 实际它们都是一样的. 下面将它统一称为序列.

首先需要注意, 序列是异步的.� 序列会产生事件, 产生事件的过程被称为随时间发射(emitting). 在�事件中携带有数据, 数据可以是数值, 也可以是手势的 tap 等.

可以把序列看做是以时间为横轴的一个圆球图.

Observable 的生命期

1---2---3 这样的序列, 每一个点都是一个 next 事件.

如果是下面这样的情况:

1---2---3---Compl
�
最后的那个就是 complete 事件, 表示这个 Observable 的生命期结束.

而 1---2---3---error, 表示这个 Observable 以错误结束.

一旦结束, 则表明该 Observable 在之后就不会再发射任何事件了.

而在 RxSwift 的源码中, Event 是一个泛型 enum. 它有三种 case:

• next: 包含有数据
• complete: 不包含任何东西
• error: 包含 Swift.error

如下所示:

/// Represents a sequence event.
///
/// Sequence grammar:
/// **next\* (error | completed)**
public enum Event<Element> {
    /// Next element is produced.
    case next(Element)
    /// Sequence terminated with an error.
    case error(Swift.Error)
    /// Sequence completed successfully.
    case completed
}

下面来实操一下 Observable.

Rx 实操

看看如何创建简单的 Observable:

    private func setupObservable() {
        example(of: "创建 Observable.") {
            let one = 1
            let two = 2
            let three = 3
            let observable = Observable.just(one)
            let obv2 = Observable.of(one, two, three)
            let obv3 = Observable.from([1, 2, 3])
        }
    }

上面就是手动创建 Observable 的简单例子.

其中 obv2 和 obv3 都是创建的 Observable<Int>, 而非 Observable<[Int]>, 即序列中的 next 事件含有的是 Int 类型数据, 而非 Int 数组数据.

另外一个着重强调的点是: 只有当 Observable 有了观察者后, 它才开始发射数据.

通过 create 操作符可以按照自己的意愿创建一个 Observable �.