minor adjustments

This commit is contained in:
Kanahia 2024-07-31 17:49:29 +05:30
parent e96cc8b5ca
commit 9a3acdc3a0

View file

@ -154,7 +154,8 @@ public class PendingUploadsPresenter implements UserActionListener {
.doOnComplete(() -> {
restartUploads(contributionList, index + 1, context);
})
.subscribe());
.subscribe(() -> WorkRequestHelper.Companion.makeOneTimeWorkRequest(
context, ExistingWorkPolicy.KEEP)));
} else {
Timber.e("Contribution already exists");
compositeDisposable.add(contributionsRepository
@ -176,7 +177,8 @@ public class PendingUploadsPresenter implements UserActionListener {
.doOnComplete(() -> {
restartUploads(contributionList, index + 1, context);
})
.subscribe());
.subscribe(() -> WorkRequestHelper.Companion.makeOneTimeWorkRequest(
context, ExistingWorkPolicy.KEEP)));
}
}
@ -201,7 +203,8 @@ public class PendingUploadsPresenter implements UserActionListener {
compositeDisposable.add(contributionsRepository
.save(it)
.subscribeOn(ioThreadScheduler)
.subscribe());
.subscribe(() -> WorkRequestHelper.Companion.makeOneTimeWorkRequest(
context, ExistingWorkPolicy.KEEP)));
}else {
Timber.e("Contribution already exists");
compositeDisposable.add(contributionsRepository
@ -215,7 +218,8 @@ public class PendingUploadsPresenter implements UserActionListener {
compositeDisposable.add(contributionsRepository
.save(it)
.subscribeOn(ioThreadScheduler)
.subscribe());
.subscribe(() -> WorkRequestHelper.Companion.makeOneTimeWorkRequest(
context, ExistingWorkPolicy.KEEP)));
}
}