如何限制retryWhen计数

文章/答案/技术大牛

发布

2回答

rx-java、rx-java2、rx-android、reactivex

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

浏览 27提问于2019-02-25得票数 0

回答已采纳

1回答

Rxjava如何处理范围？

rx-java2

我正在尝试在Rxjava中学习retryWhen。 emitter.onError(new Throwable("test")); .retryWhenTimeUnit.SECONDS); }) .subscribe(s ->

浏览 3提问于2018-01-12得票数 0

回答已采纳

2回答

如何创建具有延迟和尝试限制的RXjs RetryWhen

angular、rxjs、observable

我正在尝试使用retryWhen进行API调用(使用angular4)，失败时会重试。我希望它延迟500毫秒，然后重试。(): Observable<SomeInterface> { .retryWhen我如何将其限制为，比如说10次？谢谢!

浏览 0提问于2017-07-05得票数 31

回答已采纳

1回答

使用Rx调用两个链接的独立方法

android、rx-java、rx-android

意思是，我应该同时调用这两个方法，不管其中一个方法的结果如何。在错误回调中，我想知道哪个方法出错，或者两个方法都出错。看起来我应该使用Completable来做这件事，但我在Rx上绝对是新手。

浏览 0提问于2018-06-25得票数 0

13回答

带有延迟函数的Rxjs重试

angular、typescript、rxjs

我正在尝试使用retry和delay函数，我希望函数在1000 use的延迟后调用，但是它没有，这里有什么错误？看看控制台的输出，时间是16:22:48。canCreate: boolean; return new Observable<boolean>( const canCreate = null; // this is just n

浏览 7提问于2017-07-07得票数 50

回答已采纳

2回答

在角http.get重试失败后抛出错误

angular、reactjs、rxjs、retrywhen

我写 (errors: Observable<any>):Observable<any> => {上次重试失败后，如何获得最近的错误？

浏览 0提问于2018-02-27得票数 3

回答已采纳

3回答

RxJava使retryWhen()触发到onError()方法

android、rx-java、rx-android

但是，在尝试超过3次之后，我不能让retryWhen()触发onError()。请检查我的代码并帮助我解决这个问题。我通过阅读这两篇文章来实现Rx。TimeUnit.SECONDS); .takeUntil(RepoResult::isSuccess) .retryWhen

浏览 2提问于2016-09-30得票数 2

回答已采纳

2回答

如何在订阅角2+后API调用失败时重试

angular、rxjs、interceptor、angular-httpclient、retrywhen

replaceUrl: true }); return throwError("error occured"); } 在使用管道和添加retryWhen

浏览 6提问于2020-02-27得票数 4

回答已采纳

1回答

如何使用RxJava 2来编排重试竞赛？

java、rx-java、reactive-programming、rx-java2

考虑到没有解析器能够处理给定的文件也是可能的，因此应该对重试计数进行限制。使用这样的retryWhen ()实现指数退避相对容易： errors.zipWith(Observable.rangeretryCount -> Observable.timer((long) Math.pow(5, retryCount), TimeUnit.SECONDS))然而，建立一个并行的竞赛是我不知道如何做>

浏览 0提问于2017-06-22得票数 1

回答已采纳

1回答

如何使用RxJava repeatWhen

rx-java3

我正在尝试了解如何在RxJava中使用repeatWhen。

浏览 10提问于2020-12-05得票数 0

1回答

用catchError进行rxjs错误处理和重试

angular、rxjs

{ }), retryWhenHere I want the use `throwError` })这是我尝试过的，但不幸的是，我不知道如何将扫描计数器和

浏览 3提问于2022-03-03得票数 4

回答已采纳

2回答

角2 Http RetryWhen

angular、rxjs、observable、rxjs5、angular-http

我试图在HTTP调用中使用retryWhen。_id}]`)) return Observable.range(1, 3).zip(attempts, i => i).flatMap.retryWhen(attempts => { if(error instanceof TechnicalError

浏览 1提问于2016-12-06得票数 4

回答已采纳

2回答

RxJs轮询、错误处理、retryWhen和retryCount重置

angular、rxjs、polling

如果重试计数>Y然后显示错误消息“错误接收数据，请稍后再试”，则每X秒重试一次，最多为Y次 polling$ = combineLatest([timer(0, 1000),_filters]).pipe( this.noteDataService.getAll().pipe( retryWhen((error$) =>

浏览 7提问于2021-11-13得票数 0

6回答

：针对特定错误进行回溯重试

java、spring、spring-webflux、project-reactor、spring-webclient

我能看到方法：.retry(3, {it is WebClientResponseException && it.statusCode.is5xxServerError} ).retryBackoff 还有一个retryWhen，但我不知道如何使用它

浏览 14提问于2019-10-23得票数 25

回答已采纳

1回答

根据条件重试失败http请求，并指定应重试的次数- Angular

javascript、angular、typescript、rxjs

所以我想使用retryWhen()运算符，但在这里我不知道如何指定应该执行的尝试次数

浏览 0提问于2021-06-12得票数 0

3回答

RxJava:具有重试限制的retryWhen

couchbase、rx-java

我需要为Couchbase CAS操作实现一个重试机制，但是Couchbase网站上的示例显示了一个似乎无限期重试的retryWhen。我需要设置重试次数限制和重试次数。

浏览 2提问于2015-01-20得票数 10

3回答

可观察到的"retryWhen“延迟

javascript、angular、observable

如何在retryWhen中设置延迟import 'rxjs/add/operator/retrywhen'; http.post('https://mywebsite.azurewebsites.net/account/getip', "", { headers: headers

浏览 0提问于2016-08-25得票数 7

2回答

用rxjs实现指数退避

javascript、angular、typescript、rxjs、observable

请求的指数退避方面的实际使用示例：import { ajax } from 'rxjs/ajax'; return pipe( retryWhensubscribe(data => ha

浏览 0提问于2018-10-26得票数 10

回答已采纳

1回答

如何使RetryWhen重试抛出异常的流

rx-java、rx-java2

我正在尝试使用retryWhen来处理一个非常基本的流程。我发出了3条流量，其中一条抛出了一个IOException，在这种情况下，我会触发多达2次的重试。( RetryWhen .retryWhenInstanceOf(IOException.classSystem.out.println("Querying for Station=" + station); return Flowable.just(statio

浏览 0提问于2018-06-15得票数 0

1回答