我有几个必须逐个调用的请求：
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(...)
这两种方法都没问题,但你不能同时使用它们.
