RxJava - subscribe und warte, bis eine Variable wahr ist

Question

Ich habe gesucht, aber bisher nichts gefunden ... oder ich bin einfach verwirrt was soll ich suchen.

Was ich versuche zu tun ist, wird ein Abonnement gemacht und wird überprüft, ob die Variable X TRUE ist. Wenn nicht, wird gewartet, bis es TRUE wird und die nachfolgenden Ereignisse ausgeführt werden.

Ich bin in die Wiederholung() Methode suchen, aber nicht sicher, wie es funktioniert ... ist jeder Vorschlag sehr geschätzt ...

Answer 1

Gerade emittieren Ihre Variable in einem beobachtbaren und filter es. Sie können eine PublishSubject verwenden, um Ihre Variable zu emittieren.

PublishSubject<Boolean> subject = PublishSubject.create(); 


void updateBoolean(boolean b) { 
     subject.onNext(b); 
} 


// latter in your code 
subject.filter(b -> b) 
     .subscribe(b -> /* do something here only if b is true */);