Castopod/AntennaPod
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix NextCloud retrying without delay

Browse Source
This commit is contained in:
ByteHamster 2022-08-04 23:27:51 +02:00
parent 938df7b7fa
commit 3df3b5b50a
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
net/sync/gpoddernet/src/main/java/de/danoeh/antennapod/net/sync/nextcloud/NextcloudLoginFlow.java
View File

@ -68,14 +68,13 @@ public class NextcloudLoginFlow {
private void poll() { private void poll() {
pollDisposable = Observable.fromCallable(() -> doRequest(URI.create(endpoint).toURL(), "token=" + token)) pollDisposable = Observable.fromCallable(() -> doRequest(URI.create(endpoint).toURL(), "token=" + token))
.delay(1, TimeUnit.SECONDS) .retryWhen(t -> t.delay(1, TimeUnit.SECONDS))
.retry(60 * 10) // 10 minutes .timeout(5, TimeUnit.MINUTES)
.subscribeOn(Schedulers.io()) .subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())
.subscribe(result -> { .subscribe(result -> callback.onNextcloudAuthenticated(
callback.onNextcloudAuthenticated(result.getString("server"), result.getString("server"), result.getString("loginName"), result.getString("appPassword")),
result.getString("loginName"), result.getString("appPassword")); error -> callback.onNextcloudAuthError(error.getLocalizedMessage()));
}, Throwable::printStackTrace);
} }
public void cancel() { public void cancel() {