如何延迟forkJoin
如何延迟forkJoin
提问于 2018-06-21 05:48:47
如何在rxjs中延迟.forkJoin()？
这是我得到的，但是想要使用delay()运算符吗？
return forkJoin(
this.call1(),
this.call2(),
this.call3()
);到目前为止，我得到了这样的结论：
return of(null).pipe(
delay(5000),
switchmap(() => this.call1()),
switchmap(() => this.call2()),
switchmap(() => this.call3()))
);这是有效的，但我想使用forkJoin，我尝试了其他解决方案
return forkJoin(
of(this.call1()).pipe(delay(5000)),
of(this.call2()).pipe(delay(5000)),
of(this.call3()).pipe(delay(5000))
);但它似乎不起作用。
回答 3
Stack Overflow用户
发布于 2018-06-21 05:53:45
将delay运算符与pipe运算符一起使用
import { delay, take } from 'rxjs/operators';
import { forkJoin } from 'rxjs/observable/forkJoin';
import { of } from 'rxjs/observable/of';
return forkJoin(
of(call1()).pipe(delay(1000)),
of(call2()).pipe(delay(2000)),
of(call3()).pipe(delay(1000))
);Stack Overflow用户
发布于 2018-06-21 05:59:07
试试thiz
import { delay } from 'rxjs/operators';
return forkjoin(call1(),call2(),call3).pipe(delay(500));Stack Overflow用户
发布于 2018-06-21 06:10:02
也许这个更完整的例子会帮助你找到你需要的解决方案：
import { delay } from 'rxjs/operators';
import { Observable } from "rxjs";
import { forkJoin } from 'rxjs/observable/forkJoin';
function call1(): Observable<any> {
return new Observable<any>(observer => {
setTimeout(_ => {
observer.next('CALL1');
observer.complete();
}, 1000);
})
}
function call2(): Observable<any> {
return new Observable<any>(observer => {
setTimeout(_ => {
observer.next('CALL2');
observer.complete();
}, 2000);
});
}
function call3(): Observable<any> {
return new Observable<any>(observer => {
setTimeout(_ => {
observer.next('CALL3');
observer.complete();
}, 3000);
})
}
forkJoin(call1(), call2(), call3()).pipe(delay(5000)).subscribe(
response => console.log(response)
)页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50961190
复制相关文章
相似问题
JQuery\Javascript -将函数作为变量传递
将jQuery ID作为参数传递给JavaScript函数
jquery noUiSlider将外部javascript变量传递到函数中。
将变量作为对javascript/jquery函数的引用传递
将字段id作为javascript函数的变量传递时出错
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
