RxJava - 描述并等到变量为真

Question

我已经搜索过但到目前为止没有找到任何东西......或者我只是混淆了我应该寻找什么.

我正在尝试做的是,将进行订阅并检查变量X是否为TRUE.如果不是,它将等到它变为TRUE并执行后续事件.

我正在调查repeat()方法,但不确定它是如何工作的...任何建议都非常感谢...

Answer 1

只需在observable中发出变量即可filter.您可以使用a PublishSubject来发出变量.

 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 */);