Drop progress emissions on backpressure

This commit is contained in:
inorichi 2016-01-06 22:57:39 +01:00
parent d0089e3f5e
commit 690684bacf

View File

@ -173,6 +173,7 @@ public class PagerReaderFragment extends BaseFragment {
final AtomicInteger currentValue = new AtomicInteger(-1); final AtomicInteger currentValue = new AtomicInteger(-1);
progressSubscription = Observable.interval(75, TimeUnit.MILLISECONDS, Schedulers.newThread()) progressSubscription = Observable.interval(75, TimeUnit.MILLISECONDS, Schedulers.newThread())
.onBackpressureDrop()
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())
.subscribe(tick -> { .subscribe(tick -> {
// Refresh UI only if progress change // Refresh UI only if progress change