android - RxJava2 - 如何每次重试，除非它是 TimeoutException？

Question

我有一个 Observables 链，在它的最后，我正在通过蓝牙向设备写入一个命令，我正在等待通知。有一种情况，它可以永远在这里等待，所以我想使用 timeout - 很简单。

但问题是，每次发生任何其他问题时，我都想重试，只有在timeout发生时才应该终止-否则应该重试。此外，如果我们沿着链向下，我们将遇到也应该具有相同行为的其他重试。超时异常应该被推回到更高层(在我的例子中是交互器)。

我考虑过 retryWhen 但我不确定在那种情况下如何正确使用它。

.retryWhen { it.filter { throwable -> throwable !is TimeoutException } }

此外，很难为此编写测试，因此我更难找到正确的解决方案。

Answer 1

请尝试以下我在我的项目中使用的方法。

创建一个类(这是一个java类，如果需要你可以把它改成kotlin类)

public class RetryWithDelay implements Function<Observable<? extends Throwable>, Observable<?>> {
private static final String TAG = "RetryWithDelay";

private final int maxRetries;
private final int retryDelayInMinutes;
private int retryCount;



public RetryWithDelay(final int maxRetries, final int retryDelayInMinutes) {
    this.maxRetries = maxRetries;
    this.retryDelayInMinutes = retryDelayInMinutes;
    this.retryCount = 0;
}

@Override
public Observable<?> apply(Observable<? extends Throwable> attempts) {
    return attempts.flatMap(new Function<Throwable, Observable<?>>() {
        @Override
        public Observable<?> apply(Throwable throwable) {
            if (throwable instanceof TimeoutException) {
                return Observable.error(throwable);
            }

            if (++retryCount < maxRetries) {
                // When this Observable calls onNext, the original
                // Observable will be retried (i.e. re-subscribed).
                return Observable.timer(retryDelayInMinutes, TimeUnit.MINUTES);
            }

            // Max retries hit. Just pass the error along.
            return Observable.error(throwable);
        }
    });
}}

在 apply 方法中，它会检查异常是否是 TimeOut 的实例，它会抛出错误，否则它会继续重试您想要的 maxRetries。

然后如下传递这个类

  .retryWhen (new RetyWithDelay(3,5)) 

每 5 分钟重试 3 次。