7

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

在 RxSwift 中,这将是变量(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)

你能帮我吗?谢谢

4

1 回答 1

4

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

final BehaviorSubject<Boolean> subject = BehaviorSubject.<Boolean>create(false);
final Boolean value = subject.getValue();
于 2016-04-07T13:22:57.943 回答