本次讲解的是rxSwift机制里的Subject
它是一个什么东西呢?
它是一个可以同时作为Observable和Observer的东西。
那么下面让我来讲解他吧。
Subject有四种。
第一种是PublishSubject。
从名字上来看,它就是一个单纯的发布者。
发布给它的订阅者新的消息。
那么首先让我们先创建一个这个发布者吧。
let subject =PublishSubject<String>()
这里的泛型参数string指的就是它可以订阅到的,以及可以发布的事件类型。
我们把subject当做Observer的时候,可以使用subject.onNext("哈哈哈") 来发送事件。
而把subject当做Observable的时候,就跟订阅普通的Observable一样。
let sub1= subject.subscribe(
onNext: {print("sub1 - \($0)")}
)
那么我们把这两行代码顺序输入,并打印,会获得什么结果?
答案是没有任何的结果。
为什么呢?
因为前面已经说过,从名字上来看,它就是一个单纯的发布者!
发布给它的订阅者新的消息!
什么时候订阅什么时候接受后面消息!
还记得第一章开头是什么么?
以时间为索引的常量队列就是Observable
把时间看成一条线,我在中间进入了,我只能接受到中间时间点以后的任何消息,但我想要知道前面的?
抱歉,不行。
这是因为PublishSubject执行的是“会员制”,它只会把最新的消息通知给消息发生之前的订阅者。
这样是不是有一个明显的概念了呢?
假设在用subscribe在时间的末尾接受订阅,那么它也同样只能接受末尾后的通知消息。
我们在代码的后面继续添加两行。
subject.onNext("吼吼吼")
subject.onNext("嘿嘿嘿")
这时他的打印是
sub1 - 吼吼吼
sub1 - 嘿嘿嘿
哈哈哈不会打印,我相信已经不用我来解释了吧?
那么我们看下面代码,你认为编译器会打印什么?
let subject =PublishSubject<string>()
subject.onNext("哈哈哈")
letsub1 = subject.subscribe(
onNext: {print("sub1 - \($0)")}
)
subject.onNext("吼吼吼")
sub1.dispose()
letsub2 = subject.subscribe(
onNext: {print("sub2 - \($0)")}
)
subject.onNext("嘿嘿嘿")
是不是感觉很简单?
就像是在回答1+1=几一样?
如果有这种想法,那么Subject里的第一个机制相信你已经理解了,下面我们来讲第二个机制。
答案...
sub1 - 吼吼吼
sub2 - 嘿嘿嘿
下一章传送门:rxSwift从零开始的代码5 - 简书