我觉得我遗漏了一些非常简单的东西。我试图为fetch创建一个简单的重试,但只执行retryWhen中的代码。我使用的是React,所以我没有this.http.get的便利。也许这是from(/*promise*/)的一个问题?我试图将重试逻辑建立在this post之上。 这是我期望看到的: Getting data from fetch...
In the retryWhen
In the interval
/* repeat the previous 3 lines 3x times including the Fetch */
Giving up 相反,我得到的是: Getting
我有这样的设置:用户输入员工代码,然后对返回一些扩展数据的API进行http调用。如果代码不正确,API将以“未找到”错误进行响应。我的问题是,如果用户键入错误的代码(按照规范的要求),可观察的用户刚刚结束订阅,所以我使用retryWhen操作符来处理错误并重新订阅,期望用户输入正确的代码。
问题是,retryWhen内部的逻辑只是第一次执行错误。如果用户失败了两次,或者即使用户失败了一次,那么输入正确的代码,然后另一次输入糟糕的代码,retryWhen中的代码就无法到达。
export class EmployeeService {
constructor(private http: H
我需要一个帮助,以正确的方式捆绑我的项目。我的项目的加载页面有点慢,需要一个解决方案,所以如果您知道一些可以帮助我的东西,我会很感激的。
我的档案>
systemjs.config.js
(function(global) { // map tells the System loader where to look for things var map = {
'@angular': 'node_modules/@angular',
'moment': 'node_modules/moment
我有这样的代码:
compositeDisposable.add(RetrofitClient
.getApi()
.getData()
.flatMap(response -> {
Data data;
if (response.isSuccessful()) {
data = response.body();
//insert data to database
我是RxJS新手,还没有找到关于以下用例的明确答案:
在移动应用程序(角/Ionic)中,我需要(1)同时进行HTTP调用,并且只有当所有数据都完成时才返回数据(比如$q.all)。如果调用正确工作,我想(2)抛出一个错误,但其中一个响应中有一个嵌套值满足特定条件(即用户没有经过正确的身份验证)。因为它是一个移动应用程序,我想(3)构建一些重试尝试,如果调用不能正常工作(由于任何原因)。如果经过一定次数的重试,调用仍然失败,我想(4)抛出一个错误。
根据我的研究,forkJoin的工作方式似乎与q.all一样。我有一个提供程序返回以下内容(observableArray保存http调用)。
r