如何并行获取只有一个api调用有重试逻辑的可观察对象

文章/答案/技术大牛

发布

1回答

android、zip、rx-java2、operator-keyword、retrywhen

我想在我的android应用程序中使用RxJava实现一个逻辑，它需要三个并行的api调用。只有第三个api调用具有重试逻辑。如果在三次尝试后成功，则将对第四api进行后续调用，否则将仅将第一和第二api调用的结果传递给订户。我试图使用Zip运算符来实现这一点，但后来被第三个api<

浏览 19提问于2019-06-02得票数 1

回答已采纳

2回答

Java ExecutorService --有时比顺序处理慢？

java、multithreading、performance、executorservice

我正在编写一个简单的实用程序，它接受可调用任务的集合，并并行运行它们。我们希望所用的总时间比最长的任务所花费的时间少得多。该实用工具还添加了一些错误处理逻辑--如果任何任务失败，并且该故障可以被视为“可重试”(例如超时或用户指定的异常)，那么我们直接运行该任务。我已经围绕一个ExecutorService实现了这个实用程序。有两部分：将所有

浏览 2提问于2013-09-19得票数 0

1回答

修改两次重试之间的请求/可观察

retrofit、rx-java、retrofit2

我将rxjava(observable) + retrofit2组合在一起，向我的应用程序发出http请求。我为应用程序创建了一次OkHttpClient，不想重新创建它。我已经在可观察的级别上实现了重试逻辑-一起使用filter和retryWhen。我想要的-如果服务器端的请求完成错误，我想重试它，并发送额外的头与它。因此，我既不明白如何在retryWhen中修改可观察对象，也不

浏览 6提问于2017-03-02得票数 0

1回答

基于队列触发的函数应用未完成

azure、azure-functions、azure-function-app、azure-functions-runtime

为了缓解这一问题，我们应用了指数重试逻辑(尝试了我们自己的或polly库)，在一定的延迟时间后调用。这对一些订阅有效，但对于许多重试逻辑在第一次尝试后不尝试的情况下失败(我们在60秒延迟的情况下保持3次重试)。请注意，由于许多订阅是并行处理的，因此函数应用会根据需要自动扩容。另外，因为我们使用的是高级套餐，所以一个虚拟机总是处于开启状态。所以杀死

浏览 20提问于2020-09-25得票数 0

1回答

正确使用RxJava + Retrofit 2的方法

java、json、rx-java、retrofit2

我有这样的JSON："success":true, { "name":"\u0420\u0435\u0441\u0442首先，提供了从data数组->获取数据的方法。 return data;第二个是这个数据的model。虽然我只使用RE

浏览 4提问于2016-05-16得票数 4

回答已采纳

1回答

如何使用Web重新身份验证，然后重试REST调用

我正在使用REST，如果我的授权令牌过期了，它将返回401。当我收到401时，我想运行我的身份验证逻辑，检索一个新的令牌，然后重试我的原始调用。做这件事最好的方法是什么。现在，我有一个身份验证类，它“知道”如何使用API进行身份验证。数据访问逻辑的其余部分位于Repository对象中。Repository<e

浏览 0提问于2012-01-27得票数 1

回答已采纳

1回答

如何在使用RxSwift时显示和恢复ViewController中的API错误

ios、uiviewcontroller、error-handling、rx-swift、reactivex

我正在尝试弄清楚在处理RxSwift流时如何在ViewController层重试API调用。我知道我可以将错误包装在一个Element中，也可以返回一个流Error。在任何一种情况下，我都不清楚如何在用户的判断下“重试”操作(例如，在发布警报之后)。如果我包装了错误，我如何“向下”与API层通信以尝试重试？如果我不包装错误，我有两个问题: 1)如何</e

浏览 6提问于2016-09-18得票数 1

3回答

由于我已经开始使用subscribe，所以我将我的服务设置为返回Observable of T。在服务中，我将调用map()，而使用这些服务的组件将只使用angular2 ()来等待响应。我想构建一个所有其他服务都将使用的api服务，并在返回401错误时透明地处理刷新令牌。因此，在使用401的情况下，我首先从OAuth2端点获取一个新令牌，然后使用新令牌重试我的请求。Promise.reject(i

浏览 0提问于2016-01-21得票数 46

回答已采纳

1回答

基于逻辑的RxJava重试

retrofit、rx-java、rx-android

这里是这样的情况，我有一个使用Retrofit的API调用，该调用可能由于网络错误而失败。如果失败，我们将显示一个带有重试按钮的错误消息。当用户按下重试按钮时，我们需要重新尝试最新的可观察到的。可能的解决办法：重试:在订阅可观察到的内容之前应该使用Retry，如果出现错

浏览 15提问于2015-06-15得票数 9

回答已采纳

2回答

RxJava并行获取可观测数据

java、asynchronous、reactive-programming、observable、rx-java

我需要一些在RxJava中实现并行异步调用的帮助。我选择了一个简单的用例，其中第一个调用获取(而不是搜索)要显示的产品(Tile)列表。(Tile)6,7:获取可观察的评论和可观察的</em

浏览 0提问于2014-10-08得票数 56

回答已采纳

1回答

如何强制执行3960的快照隔离失败？

sql、sql-server、sql-server-2008、tsql、snapshot

Story问题如何</

浏览 1提问于2012-04-04得票数 4

1回答

在Scala中存储和共享用于服务访问的cookie

scala、cookies、scalatra

我有一个Scalatra 2.3应用程序，它使用Dispatch来联系遗留服务获取一些数据。一些API调用使用基于cookie的auth。我想避免单独登录到这些安全端点的每一个请求。我的第一次尝试是一个伙伴对象，它有一个var for cookie和一个函数getCookie。这要么从var返回存储的cookie，要么进行身份验证，存储接收到<e

浏览 3提问于2014-12-09得票数 0

回答已采纳

2回答

我不能从Hacker新闻API中得到故事

angular、typescript

this.service.getItems(this.topIds).subscribe(data => this.topNews = data);topIds工作得很好，但由于某种原因，topNews返回空数组，不确定如何使其工作谢谢你的帮助！

浏览 6提问于2022-01-29得票数 0

回答已采纳

2回答

使用RX Android进行并行API调用

android、kotlin、retrofit、rx-java2

我有两个不同的端点，用于为用户获取数据。我正在对RX适配器工厂进行改造。如果我按顺序调用单个方法中的两个端点，它是否被认为是在两个不同线程上执行的并行调用。如果不是，如何使用RX使这些API调用并行？或者一种在并行获取数据的同时获得响应的方法。例如，第一个端点可能需要5秒，第二个端点需要7秒，

浏览 0提问于2021-01-27得票数 0

回答已采纳

1回答

如何使用TestScheduler测试对RxJS Observable的重新订阅？

unit-testing、rxjs

我有一个可能抛出错误的观察值。当它抛出时，我想重新订阅该可观察对象，然后重试。例如，使用retry()运算符。为了测试这个重试逻辑，我需要创建一个测试可观察对象，它将在订阅的前2次抛出一个错误，并且只有在第3次才会产生一个值。instead expectObservable(retryMultip

浏览 25提问于2020-01-23得票数 0

1回答

在另一个作业完成时通知作业

kotlin、jobs、kotlin-coroutines

在我的应用程序中，所有请求都需要一个令牌作为http授权头，它会在一定时间后过期。当一个作业通过401状态码从服务器获取时，我需要启动该作业来刷新令牌。当此作业完成时，我需要通知应用程序中的所有作业，因为我不知道其中哪个作业失败(作业已完成，但状态为401http)，并且我必须使用新的令牌重试。我如何使用协程来做这件事？

浏览 0提问于2019-04-16得票数 0

1回答

无法使用服务实例调用可注入函数。参数值始终为空。

angular、rxjs

进行令牌刷新api调用的逻辑已放置在我在providers数组@NgModule(中声明的可注入函数中。，只有作者将逻辑存储到可导出的常量中。下面是我如何调用retryWhen逻辑的一个例子： private injector: Inject

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

回答已采纳

3回答

不带订阅的Angular RxJS HttpPost

angular、rxjs、http-post、rxjs-observables

在使用RxJs的Angular中，所有数据检索都是通过Observables和html中的async管道完成的。这是在Component中避免Subscriptions的正确方法。在将数据发布到服务器时，如何实现相同的目标？我没有可以等待此调用的视图，但我想从我的组件中删除.subscribe()。

浏览 18提问于2021-04-20得票数 0

1回答

客户视角下的幂等键

rest、http、microservices

假设我有一个调用下游服务API的API，名为/charge (POST)。假设在充电时，反向代理发生了超时，我得到了一个5xx。但指控确实发生了。在这种情况下，我会用一个5xx来回应我的消费者。现在，如果使用者使用相同的幂等键调用，则他的请求可以成功，因为下游服务将返回响应的缓存副本。但是，如果他在调用我的A

浏览 1提问于2019-11-14得票数 0

1回答

使用java rx.Observable进行并行API调用

java、observable、reactive-programming、rx-java2、rx-javafx

我有一个Set<Object>，对于Set中的每个条目，我必须进行一个API调用，并将其作为参数传递。我必须处理这些响应中的每一个，并使用自己的逻辑填充另一个MapList<MyResponse> responses = newArrayList<>(); Set<StoreNode>processResponse(response,

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

点击加载更多