本次讲解的是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 - 简书