mnalis/apps-android-commons
1
0
Fork 0
mirror of https://github.com/commons-app/apps-android-commons.git synced 2025-11-04 08:43:52 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Implemented retry with delay of 5000ms

Browse source
This commit is contained in:
Kanahia 2024-06-06 11:52:50 +05:30
parent a94e8b4b1a
commit bc7ed146d9
1 changed files with 21 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

21
app/src/main/java/fr/free/nrw/commons/nearby/fragments/NearbyParentFragment.java
View file

@ -107,6 +107,7 @@ import io.reactivex.schedulers.Schedulers;
import java.io.File; import java.io.File;
import java.io.FileOutputStream; import java.io.FileOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InterruptedIOException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
@ -1263,6 +1264,16 @@ public class NearbyParentFragment extends CommonsDaggerSupportFragment
compositeDisposable.add(nearbyPlacesInfoObservable compositeDisposable.add(nearbyPlacesInfoObservable
.subscribeOn(Schedulers.io()) .subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())
.retryWhen(errors -> errors
.zipWith(Observable.range(1, 4), (throwable, retryCount) -> {
if (throwable instanceof InterruptedIOException && retryCount < 4) {
Timber.d("Retry attempt %d due to %s", retryCount, throwable.getMessage());
return retryCount;
}
throw new Exception(throwable);
})
.flatMap(retryCount -> Observable.timer(5, TimeUnit.SECONDS))
)
.subscribe(nearbyPlacesInfo -> { .subscribe(nearbyPlacesInfo -> {
if (nearbyPlacesInfo.placeList == null || nearbyPlacesInfo.placeList.isEmpty()) { if (nearbyPlacesInfo.placeList == null || nearbyPlacesInfo.placeList.isEmpty()) {
showErrorMessage(getString(R.string.no_nearby_places_around)); showErrorMessage(getString(R.string.no_nearby_places_around));
@ -1300,6 +1311,16 @@ public class NearbyParentFragment extends CommonsDaggerSupportFragment
compositeDisposable.add(nearbyPlacesInfoObservable compositeDisposable.add(nearbyPlacesInfoObservable
.subscribeOn(Schedulers.io()) .subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())
.retryWhen(errors -> errors
.zipWith(Observable.range(1, 4), (throwable, retryCount) -> {
if (throwable instanceof InterruptedIOException && retryCount < 4) {
Timber.d("Retry attempt %d due to %s", retryCount, throwable.getMessage());
return retryCount;
}
throw new Exception(throwable);
})
.flatMap(retryCount -> Observable.timer(5, TimeUnit.SECONDS))
)
.subscribe(nearbyPlacesInfo -> { .subscribe(nearbyPlacesInfo -> {
if (nearbyPlacesInfo.placeList == null || nearbyPlacesInfo.placeList.isEmpty()) { if (nearbyPlacesInfo.placeList == null || nearbyPlacesInfo.placeList.isEmpty()) {
showErrorMessage(getString(R.string.no_nearby_places_around)); showErrorMessage(getString(R.string.no_nearby_places_around));