2016-04-07 9 views
7

ich mit RxJava beginnen, und ich möchte eine beobachtbare schaffen, die den letzten Zustand zu retten ...RxJava beobachtbar letzten Zustand

In RxSwift, das wäre Variable sein (https://github.com/ReactiveX/RxSwift/blob/master/Documentation/GettingStarted.md#variables), aber ich kann nicht eine equivalente in RxJava gefunden ...

ich eine Arbeit um gefunden, aber es ist eine Menge von Kesselblech Code

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(); 
} 

die RxSwift Äquivalent dieses

ist

Können Sie mir bitte helfen? Dank

Antwort

4

BehaviorSubject hat eine Wert() Methode, die gibt es aktuellen Wert

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

Dank ist viel, das war genau das, was ich gesucht :) Wenn Sie mir eine Frage erlauben. Gibt es eine Möglichkeit, dieses BehaviorSubject zu abonnieren, seinen letzten Wert zu erhalten und weiterhin die nächsten Ereignisse zu erhalten? –

+1

Sie könnten den Replay-Operator verwenden (mit einer Kapazität von 1). – JohnWowUs

+0

Danke, es hat funktioniert :) –

Verwandte Themen