RxSwift发送及订阅 Subjects、Variables代码示例

2023-07-08 20:18:06 91

Subjects介绍

1.Subjects是订阅者，也是Observable

订阅者：它能动态的接收新的值。

Observable：当Subjects有了新值后会通过Event将新值发出给他的所有订阅者。

2.常用的方法

onNext(:)：是on(.next(:))的简便写法。该方法相当于subject接收到一个.next事件。
onError(:)：是on(.error(:))的简便写法。该方法相当于subject接收到一个.error事件。
onCompleted()：是on(.completed)的简便写法。该方法相当于subject接收到一个.completed事件。

3.Subjects有四种PublishSubject、BehaviorSubject、ReplaySubject、Variable

相同点

都是Observable，他们的订阅者都能接收他们发出的新的Event
直到Subject发出.complete或者.error的Event后，该Subject便终结了，同时它也就不会再发出.next事件。
对于那些在Subject终结后再订阅他的订阅者，也能收到subject发出的一条.complete或.error的event，告诉这个新的订阅者它已经终结了。

不同点

PublishSubject
最普通的Subject，不需要初始值就能初始化。
他的订阅者只能收到他们订阅后的Event。

letsub=PublishSubject()

sub.onNext("订阅之前的不能接收到")

sub.subscribe{eventin
print(event.element)
//Optional("订阅之后的可以接收到")
//nil
}.disposed(by:disposeBag)

sub.onNext("订阅之后的可以接收到")
//结束
sub.onCompleted()
///结束之后添加的订阅能收到completed
sub.subscribe{eventin
print(event)
}
sub.onNext("结束后发的都收不到")

BehaviorSubject

需要一个默认值初始化

当一个订阅者订阅之后会立马收到上一个Event，之后就是正常情况发一个收一个。

onCompleted()之后的订阅者也只能收到Completed。

letsub=BehaviorSubject(value:"默认值")

sub.subscribe{eventin
print("订阅1",event)
}.disposed(by:disposeBag)
sub.onNext("发送1")
sub.subscribe{eventin
print("订阅2",event)
}.disposed(by:disposeBag)
sub.onCompleted()
sub.subscribe{eventin
print("订阅3",event)
}.disposed(by:disposeBag)

订阅1next(默认值)
订阅1next(发送1)
订阅2next(发送1)
订阅1completed
订阅2completed
订阅3completed

ReplaySubject

创建的时候需要一个参数bufferSize设置记录个数

新添加的订阅会接收到之前发送的两个Event，如果不足两个就只接收一个。

如果超过两个只接收最新的两个。

如果订阅时已经结束除了会接收到最新的两个Event外还有结束的complete或error。

letsub=ReplaySubject.create(bufferSize:2)

sub.subscribe{eventin
print("订阅1",event)
}.disposed(by:disposeBag)
sub.onNext("发送1")
print("-------")
sub.subscribe{eventin
print("订阅2",event)
}.disposed(by:disposeBag)

sub.onNext("发送2")
sub.onNext("发送3")
sub.onNext("发送4")
print("-------")
sub.subscribe{eventin
print("订阅3",event)
}.disposed(by:disposeBag)
sub.onCompleted()
print("-------")
///不仅会收到最后的两个event还有Completed
sub.subscribe{eventin
print("订阅4",event)
}

订阅1next(发送1)
-------
订阅2next(发送1)
订阅1next(发送2)
订阅2next(发送2)
订阅1next(发送3)
订阅2next(发送3)
订阅1next(发送4)
订阅2next(发送4)
-------
订阅3next(发送3)
订阅3next(发送4)
订阅1completed
订阅2completed
订阅3completed
-------
订阅4next(发送3)
订阅4next(发送4)
订阅4completed

BehaviorRelay

基本同BehaviorSubject功能一样，但是不能主动调用onCompleted和error，会在BehaviorRelay释放前调用

letsub=BehaviorRelay(value:"初始值")

sub.subscribe{eventin
print("第一次订阅",event)
}.disposed(by:disposeBag)
sub.accept("新值1")
sub.subscribe{eventin
print("第二次订阅",event)
}.disposed(by:disposeBag)

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

RxSwift发送及订阅 Subjects、Variables代码示例

热门推荐

随机推荐