如何在计数时限制重试 [英] How to limit retryWhen count

问题描述

我在retryWhen中使用了PublishSubject，以允许用户重试该操作，类似于this answer。一切正常，但有一个问题-在用户点击重试3次后，我应该不再允许重试，并应该中止操作。有没有办法将重试次数限制在3次以内？ 我已尝试PublishSubject.Take(3)运算符，但不起作用。

推荐答案

运算符(如retryWhen)具有次要流，其结果会影响主要流。因此，流操作也可以在这个次级流上执行，因此您可以应用各种运算符来塑造其结果：

改编：https://stackoverflow.com/a/47677308/61158

final PublishSubject<Object> retrySubject = PublishSubject.create();

disposable.add(
    getData()
    .doOnError(throwable -> enableButton())
    .retryWhen(observable -> 
        observable.zipWith(retrySubject, 
             (o, o2) -> o
        )
        .take(3)  // <------------------------ maximum 3 items from the secondary sequence
        .concatWith(Observable.error(new RetriesExhaustedException()));
     )
    .subscribeWith(/* do what you want with the result*/)
);

这篇关于如何在计数时限制重试的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！