专栏首页吴老师移动开发【iOS开发】RxSwift中的Subject(PublishSubject/BehaviorSubject/ReplaySubject/Variable)

【iOS开发】RxSwift中的Subject(PublishSubject/BehaviorSubject/ReplaySubject/Variable)

RxSwift中有四种类型的Subject:

  • PublishSubject: 只会发送新的事件给订阅者,订阅之前的事件不会发送。
  • BehaviorSubject:有一个初始值,重复发送或者是发送最新的事件给订阅者。
  • ReplaySubject:可以指定一个buffer size,它会通过这个buffer 来缓存最近发送的事件,通过buffer size的大小就是缓存事件的个数。当有新的订阅者是,它会把缓存的事件发送给新的订阅者。
  • Variable:相当于一个BehaviorSubject的封装,它会保存当前值做为自身的一个状态,发送当前的状态给新的订阅者。

一、PublishSubject

功能解析

PublishSubject 即是一个被观察者(Observable)也是一个观察者 (Observer)

看上面的Marble diagram图: 第一条线是一个PublishSubject,第二、第三条是订阅者,向上的箭头表示订阅者订阅Subject,向下的箭头表示Subject发送事件。 第一个订阅者在1事件发送后才订阅,所以它不会收到1事件,它会收到2.3事件。第二个订阅者在2事件发送出来后才订阅,所以它只会收到3事件。

PublishSubject 的next事件只会发送给当前已经订阅这个subject的订阅者,新的订阅者不会收到订阅之前发送的事件。

Subject终止之后,再去订阅,会给后面的订阅者发送它的终止事件。所有的subject都是如此。

示例代码

example("PublishSubject") { 
    let subject = PublishSubject<String>()
    
    subject.onNext("1")
    
    let subscriptionOne = subject.subscribe(onNext: { (element) in
        print("订阅者一:" + element)
    })
    
    subject.on(.next("2"))
    
    let subscriptionTwo = subject.subscribe(onNext: { (element) in
        print("订阅者二:" + element)
    })
    
    subject.onNext("3")
}

输出:

--- PublishSubject example ---
订阅者一:2
订阅者一:3
订阅者二:3

二、BehaviorSubject

功能解析

BehaviorSubject跟PublishSubject相似,只是它会发送最近的一个next事件给新的订阅者。如上面的Marble diagram: 第一条线是一个BehaviorSubject,第二、第三条是订阅者,向上的箭头表示订阅者订阅Subject,向下的箭头表示Subject发送事件。 第一个订阅者在事件1后订阅subject,它会立马收到最近的一个next事件,也就是1.之后的事件正常接收。 第二个订阅者在事件2后订阅subject,它会立马收到最近的一个next事件,也就是2.之后的事件正常接收。

示例

enum MyError: Error {
    case anError
}

func print<T: CustomStringConvertible>(label: String, event: Event<T>) {
    print(label, event.element ?? event.error ?? event)
}

example("BehaviorSubject") { 
    let subject = BehaviorSubject(value: "1")
    
    let disposeBag = DisposeBag()
    
    subject.subscribe({ (event) in
        
        print(label: "订阅者一:", event: event)
    })
    .disposed(by: disposeBag)
    
    subject.onNext("2")
    
    subject.onError(MyError.anError)
    
    subject.subscribe({ (event) in
        print(label: "订阅者二:", event: event)
    })
    .disposed(by: disposeBag)
}

输出:

--- BehaviorSubject example ---
订阅者一: 1
订阅者一: 2
订阅者一: anError
订阅者二: anError

三、ReplaySubject

功能解析

Replay subjects 可以指定一个buffer size,它会通过这个buffer 来缓存最近发送的事件,通过buffer size的大小就是缓存事件的个数。当有新的订阅者是,它会把缓存的事件发送给新的订阅者。

上面的Marble diagram: 第一条线是一个buffer size为2的ReplaySubject,它会缓存最近的两个事件,第二、第三条是订阅者,向上的箭头表示订阅者订阅Subject,向下的箭头表示Subject发送事件。 第一个订阅者在一开始就订阅了,所以它可以收到,1、2、3事件 第二个订阅者在事件2后面才订阅,因为ReplaySubject的buffer size为2,所以第二个订阅者会立马收到缓存的1、2事件。3事件正常接收。

需要注意的点

ReplaySubject的缓存是缓存在内存里面的,所以,如果ReplaySubject发送的是图片,就不能将buffer size设置的太大,很容易造成内存压力。发送的是数组也一样。所以这里一定要注意内容压力,看类型,不能将buffer size设置过大。

示例

example("ReplaySubject") { 
    let subject = ReplaySubject<String>.create(bufferSize: 2)
    let disposeBag = DisposeBag()
    
    subject.onNext("1")
    subject.onNext("2")
    subject.onNext("3")
    
    subject.subscribe({ (event) in
        print(label: "订阅者一:", event: event)
    })
    .disposed(by: disposeBag)
}

输出:

--- ReplaySubject example ---
订阅者一: 2
订阅者一: 3

四、Variable

功能解析

Variable要指定一个初始值,它会保存当前值做为自身的一个状态,并发送它的初始值或者最新值给新的订阅者。 可以通过它的value属性来读取到它的最新值。 不能给它发送完成或者错误事件,它会在释放的时候自动完成。

示例

example("Variable") { 
    var variable = Variable("1")
    let disposeBag = DisposeBag()
    
    variable.asObservable().subscribe({ (event) in
        print(label: "订阅者一:", event: event)
    })
    .disposed(by: disposeBag)
    
    variable.value = "2"
}

正在系统的学习Swift,RxSwift,欢迎交流!点个关注,不定期更新。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 【iOS开发】Cocoapods详解-使用及创建私有库

    CocoaPods现在是通过target来组织的,如果项目有多个target,可以写多个target为每个target引入不同的第三方库。 写法:

    吴老师
  • 【iOS开发】UITableView和UICollectionView多种类型cell处理,更好地组织代码

    开发不仅仅是完成功能,还要写出认后来人可以很容易上手维护的代码。今天就记录一下列表数据,多种类型cell时,如何更好的组织代码。从实际需求场景出发,先看一下UI...

    吴老师
  • 【iOS开发】启动时间优化,runloop的一个小技术点

    刚接触项目不久,最近产品说有一个点要优化,App的启动页面显示时间太长了。一直在开发其它的app,还真没注意这个点,去看了一下还真是,有的时候启动页面的显示时间...

    吴老师
  • 【iOS开发】UITableView优化

    移动开发中,任何一个应用都或多或少的有列表的存在,列表的上下滑动直接关系到用户体验。如果处理不好,就会使得列表滑动起来有明显的卡顿效果。所以对列表的优化,让它更...

    吴老师
  • 【iOS开发】RxSwift入门:从Observable.create讲起

    刚学习RxSwift的时候,到github看文档,搜索别人的博客。基本上都是从那些例子讲起,像下面这样,自己再跟着用playground写一篇。

    吴老师
  • 【iOS开发】一些不错的文章博客整理

    吴老师
  • 【iOS开发】iOS 动画详解

    在移动开发中,为了提高用户体验,会用到一些动画来提高应用的视觉效果。让人有眼前一亮的感觉。同时有动画的过渡过程,会让应用看起来不是那么的生硬,更吸引用户。

    吴老师
  • 如何在Linux,Mac或Windows上安装Git

    Git是由Linus Torvalds为Linux内核设计开发的。Git为非线性的分布式开发提供了支持,允许多个项目成员同时在一个项目上进行开发。Git是最流行...

    Techeek
  • 【iOS开发】浅谈iOS列表分页数据管理

    @property (nonatomic, copy) NSMutableArray *list; @property (nonatomic) NSInteg...

    吴老师

扫码关注云+社区

领取腾讯云代金券