Aae4ccbf20255809be2f25e0838c4635
跟我学 RxSwift03 - Observable 介绍及使用

在写第三篇文章之前,首先得所一声抱歉,由于这段时间较忙,所以就一直没时间着手写第三篇文章,实在是不好意思。下面咱们言归正传,开始今天的内容:

在上小节RxSwift的环境搭建及简单使用中,我们提到了 Observable,那Observable到底是什么?本节我们就来揭开它神秘的面纱。

一、Observable - 可观察序列

Observable.png
在ReactiveX中,Observable<T>代表的是一个可观察序列,从字面意思可以看出这是在观察者模式中的被观察者,它会向观察对象发送事件序列。Observable 可以用于描述元素异步产生的序列,我们生活中许多事物都可以通过它来表示,例如:
- Observable<Double> 温度
我们可以将温度看作是一个序列,然后监测这个温度值,最后对这个值做出响应。如:当室温高于 30 度时,打开空调降温。

温度.png

  • Observable<OnePieceEpisode> 《火影忍者》动漫 我们也可以把《火影忍者》动漫看作是一个序列。然后当《火影忍者》更新一集时,我们就立即观看这一集。

动漫.png

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

JSON.png

  • Observable<Void> 任务回调 你可以把任务回调看作是一个序列。当任务结束后,提示用户任务已完成。

任务回调.png

. . .
. .

上面列举了这么多,那可观察序列到底有什么用呢?
- 可以异步地产生一系列的 Event(事件),即一个 Observable<T> 对象会随着时间推移不定期地发出 event(element : T) 。
- Event 可以携带数据,它的泛型 <T> 用来指定这个Event携带的数据的类型。
- 有了可观察序列,我们还需要有一个Observer(订阅者)来订阅它,这样订阅者才能收到 Observable<T> 不时发出的 Event。

二、Event - 事件

让我们来看看 RxSwift 源码中 Event 的定义 :

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
}

很明显,Event 是一个枚举,也就是说一个 Observable 可以发出 3 种不同类型的 Event 事件:
- next: next 事件就是可以携带数据 <T> 的事件

next事件

  • error: error 事件表示一个错误,它可以携带具体的错误内容,一旦 Observable 发出了error event,则这个 Observable 就等于终止了,以后它再也不会发出 event 事件了。

error事件

  • completed: completed 事件表示 Observable 发出的事件正常地结束了,跟 error 一样,一旦 Observable 发出了 completed event,则这个 Observable 就等于终止了,以后它再也不会发出 event 事件了。

completed事件

为了更好地理解, 我们将 Observable 和 Swift 中的 Sequence 进行对比 :

三、Observable 与 Sequence比较

  • 一个 Observable(ObservableType) 相当于一个序列 Sequence(SequenceType)
  • ObservableType.subscribe(_:) 方法相当于 SequenceType.generate()

两者的区别在于:
- Swift 中的 SequenceType 是同步的循环,而 Observable 是异步的。
- Observable 对象会在有任何 Event 时候,自动将 Event 作为一个参数通过 ObservableType.subscribe(_:) 发出,并不需要使用 next 方法。

说了这么多,该怎么创建 Observable 序列呢,有如下几种方法?

四、创建 Observable 序列

  • 1. create() create 通过指定的方法实现来自定义一个被观察的序列。该方法接受一个 block 形式的参数,任务是对每一个过来的订阅进行处理。
// 回调参数 observer 就是订阅 Observable 对象的订阅者
// 当一个订阅者订阅Observable对象的时候,就会将订阅者作为参数传入block执行一些内容
let observable = Observable<String>.create{ observer in
    // 对订阅者发出了.next事件,且携带了一个数据"https://github.com/VictDog"
    observer.onNext("https://github.com/VictDog")
    // 对订阅者发出了.completed事件
    observer.onCompleted()
    // 因为一个订阅行为会有一个Disposable类型的返回值,所以在结尾一定要returen一个Disposable
    return Disposables.create()
}

// 订阅测试
observable.subscribe {
    print($0)
}

运行结果如下:
create运行结果
- 2. just()
just 通过传入一个默认值进行初始化:

// Observable<Int>,即指定了这个 Observable 所发出的事件携带的数据类型必须是 Int 类型的
let observable = Observable<Int>.just(1)
  • 3. of() of 可以接受可变数量的参数(必需要是同类型的)
// 这里没有声明 Observable 的泛型类型,因为Swift 会自动推断类型
let observable = Observable.of("A", "B", "C")
  • 4. from() from 需要传递一个数组参数
// 效果同上面的 of 是一样的
let observable = Observable.from(["A", "B", "C"])
  • 5. empty() empty 会创建一个空内容的 Observable 序列
let observable = Observable<Int>.empty()
  • 6. never() never 会创建一个永远不会发出 Event(也不会终止)的 Observable 序列
let observable = Observable<Int>.never()
  • 7. error() error 会创建一个不做任何操作,而是直接发送错误的 Observable 序列
enum MyError: Error {
    case A
    case B
}

let observable = Observable<Int>.error(MyError.A)
  • 8. range() range 通过指定起始和结束数值,创建一个以这个范围内所有值作为初始值的Observable序列
// 下面两种方法创建的Observable序列相同
// 使用range
let observable = Observable.range(start: 1, count: 5)
// 使用of
let observable = Observable.of(1, 2, 3 ,4 ,5)
  • 9. repeatElement() repeatElement 会创建一个可以无限发出给定元素的 Event 的 Observable 序列(永不终止)。
let observable = Observable.repeatElement(1)
  • 10. generate() generate 会创建一个只有当提供的所有的判断条件都为 true 的时候,才会给出动作的 Observable 序列
// 下面两种方法创建的 Observable 序列相同
// 使用generate()方法
let observable = Observable.generate(
    initialState: 0,
    condition: { $0 <= 10 },
    iterate: { $0 + 2 }
)

// 使用of()方法
let observable = Observable.of(0 , 2 ,4 ,6 ,8 ,10)
  • 11. deferred() deferred 方法相当于是创建一个Observable 工厂,通过传入一个 block 来执行延迟 Observable 序列创建的行为,而这个 block 里就是真正的实例化序列对象的地方。
// 用于标记是奇数、还是偶数
var isOdd = true
// 使用deferred()方法延迟Observable序列的初始化,通过传入的block来实现Observable序列的初始化并且返回
let factory : Observable<Int> = Observable.deferred {
    // 让每次执行这个block时候都会让奇、偶数进行交替
    isOdd = !isOdd
    // 根据isOdd参数,决定创建并返回的是奇数Observable、还是偶数Observable
    if isOdd {
        return Observable.of(1, 3, 5 ,7,9)
    } else {
        return Observable.of(2, 4, 6, 8,10)
    }
}

// 第1次订阅测试
factory.subscribe { event in
    print("\(isOdd)", event)
}

// 第2次订阅测试
factory.subscribe { event in
    print("\(isOdd)", event)
}

运行结果如下, 可以看到两次订阅得到的 Observable 是不一样的:
deferred运行结果
- 12. interval()
interval 每隔一段设定的时间,会发出一个索引数的元素,而且它会一直发送下去。

// 在主线程,每隔一秒发送一次
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable.subscribe { event in
    print(event)
}

interval运行结果
- 13. timer()

// 用法一:
// 5秒种后发出唯一的一个元素0
let observable = Observable<Int>.timer(5, scheduler: MainScheduler.instance)
observable.subscribe { event in
    print(event)
}

// 用法二:
// 延时5秒种后,每隔1秒钟发出一个元素
let observable = Observable<Int>.timer(5, period: 1, scheduler: MainScheduler.instance)
observable.subscribe { event in
    print(event)
}

用法二运行结果:
timer用法二运行结果

OK,今天的内容就到此为止,祝大家学习愉快。 每天进步一点点,加油!!!
下节预告:跟我学RxSwift04 - Observable订阅、事件监听、订阅销毁

© 著作权归作者所有
这个作品真棒,我要支持一下!
RxSwift系列教程, 从多个方面逐一介绍RxSwift的使用方法,不仅会介绍RxSwift的核心内容: 1. ...
2条评论
揭翔
#1

期待更新

victory
#2

#1楼 @揭翔 谢谢支持。因个人原因,文章断更,实在抱歉。 最近会继续更新,尽请关注。

top Created with Sketch.