angular – flatMap中请求之间的延迟

发布时间：2020-12-17 17:03:12 所属栏目：安全来源：网络整理

导读：我有几个必须逐个调用的请求： this.firstRequest().flatMap(resp = { //check response if(!response.success) { return Observable.throw('some message'); } return this.secondRequest();}).subscribe(...)firstRequest() { // build params and call ht

我有几个必须逐个调用的请求：

this.firstRequest()
.flatMap(resp => {
   //check response
   if(!response.success) {
      return Observable.throw('some message');
   }

   return this.secondRequest();
})
.subscribe(...)

firstRequest() {
 // build params and call http service
 return this.service.getData(...)
   .do(r => {
      if(r.success) {
         this.localStorage.save('code',r.code)
      }
    })
 .delay(5000); 
}

如您所见,第一次和第二次请求之间存在延迟.但是,只有当成功领域成立时我才需要延迟.我该怎么做？

解决方法

方法1：

如果你只想在firstRequest()方法中完成它,那么你可以做的是通过.flatMap()中的.of()返回不同的observable：

firstRequest() {
    // build params and call http service
    return this.service.getData(...)
        .flatMap(r=>{
            if(r.success) { 
                this.localStorage.save('code',r.code);
                //delay for 500ms,then return the same response back
                return Observable
                    .delay(500)
                    .of(r);
            }
            //not successful,dont delay. return the original Observable
            return Observable.of(r);
        })
}

方法2：

如果你想在方法之外做,那么你可以这样做：

this.firstRequest()
    .flatMap(resp => {
        //check response
        if(!response.success) {
            return Observable.throw('some message');
        }
        return Observable
            .delay(500)
            .flatMap(()=>this.secondRequest())
    })
    .subscribe(...)

这两种方法都没问题,但你不能同时使用它们.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!