RxJava osservabile con ultimo stato

Question

sto iniziando con RxJava, e vorrei creare un osservabile che può salvare l'ultimo stato ...

In RxSwift, che sarebbe variabile (https://github.com/ReactiveX/RxSwift/blob/master/Documentation/GettingStarted.md#variables), ma non ci riesco trovato un equivalente in RxJava ...

ho trovato un lavoro in giro, ma è un sacco di codice refusi

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

l'equivalente RxSwift è questo

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

Potete aiutarmi per favore? Grazie

Answer 1

BehaviorSubject ha un metodo value(), che restituisce il suo valore corrente

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