Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <T> SingleTransformer<T, T> get() {
- return single -> single.retry((retryCount, throwable) -> {
- boolean isRetryNecessary = false;
- if (retryCount <= MAX_RETRIES) {
- ExceptionCause cause = getCause(throwable);
- if (cause == ExceptionCause.SSL) {
- handleIt();
- isRetryNecessary = true;
- }
- if (cause != ExceptionCause.OTHER) {
- registerUser();
- isRetryNecessary = true;
- }
- }
- return isRetryNecessary;
- });
- Single registerUser() {
- return Single.fromFuture(ApiCallRegister())
- .subscribeOn(Schedulers.io())
- .unsubscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement