I have the following method:
public class ParentalControlInteractor {
public Single<Boolean> isPinSet() {
return bamSdk.getPinManager().isPINSet();
}
}
I want to call this function to run once, then repeat every minute until infinity but this seems clumsy:
parentalControlInteractor.isPinSet()
.subscribeOn(Schedulers.io())
.repeat(10000)
.timeout(1600,TimeUnit.MILLISECONDS)
.doOnError(throwable -> {
Timber.e(throwable,"Error getting if Pin is set");
throwable.printStackTrace();
})
.subscribe(isPinSet -> {
this.isPinSet = isPinSet;
Timber.d("Pin is set = " + isPinSet.toString());
});
Isn't there a better way to do it? I'm using RxJava2. Also, the method above only calls it 10000 times. I want to call it forever, like using Handler.postDelayed().
you can use interval()
oberator here is the code
DisposableObserver<Boolean> disposable =
Observable.interval(1, TimeUnit.MINUTES)
.flatMap(aLong -> isPinSet().toObservable())
.subscribeOn(Schedulers.io())
.subscribeWith({isPinSet -> doSomething()}, {throwable -> handleError()}, {});
if you want to finish this operation at any time call disposable.dispose()
Try
.repeatWhen(objectFlowable -> Flowable.timer(10, TimeUnit.SECONDS).repeat())
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With