RxJava Observable具有最后状态

发布时间：2020-12-15 00:40:26 所属栏目：Java 来源：网络整理

导读：我从Rx Java开始,我想创建一个可以保存最后状态的observable … 在RxSwift中,那将是Variable(https://github.com/ReactiveX/RxSwift/blob/master/Documentation/GettingStarted.md#variables),但我在RxJava中找不到等价物…… 我找到了一个解决方案,但它是很

我从Rx Java开始,我想创建一个可以保存最后状态的observable …

在RxSwift中,那将是Variable(https://github.com/ReactiveX/RxSwift/blob/master/Documentation/GettingStarted.md#variables),但我在RxJava中找不到等价物……

我找到了一个解决方案,但它是很多锅炉板代码

private boolean isGettingCompanies = false;

public boolean isGettingCompanies() {
    return isGettingCompanies;
}

private void setIsGettingCompanies(boolean isGettingCompanies) {
    this.isGettingCompanies = isGettingCompanies;
    isGettingCompaniesPublishSubject.onNext(isGettingCompanies);
}

private final PublishSubject<Boolean> isGettingCompaniesPublishSubject = PublishSubject.create();

public Observable<Boolean> isGettingCompaniesPublishSubject() {
    return isGettingCompaniesPublishSubject.asObservable();
}

RxSwift等价于此

private(set) var isGettingCompanies: Variable = Variable(false)

你能帮我吗？谢谢

解决方法

BehaviorSubject有一个value()方法,它返回它的当前值

final BehaviorSubject<Boolean> subject = BehaviorSubject.<Boolean>create(false);
final Boolean value = subject.getValue();

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!