【iOS开发】RxSwift中的Subject(PublishS

作者: Brant白叔 | 来源:发表于2017-08-08 16:58 被阅读448次

    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,欢迎交流!点个关注,不定期更新。

    相关文章

      网友评论

        本文标题:【iOS开发】RxSwift中的Subject(PublishS

        本文链接:https://www.haomeiwen.com/subject/inztrxtx.html