- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我正在尝试在名为 processes
的组件中填充一个数组,它是一个 process
数组。每个进程
还有一个任务
列表。
所以目前,我正在处理两个 api 调用,它们是:
/进程
和/process/{processId}/tasks
我使用 /processes
获取所有进程并最初填充 processes
数组。然后我使用每个 process
的进程 id 调用第二个 API 来获取该进程的任务。
目前,我的代码看起来像这样:
this.processes.forEach((process, index) => {
myService.getTasks().subscribe((tasks) => {
process.tasks = tasks;
})
})
我知道我可以创建一个 observable 数组,并使用 Observable.forkJoin()
等待所有这些异步调用完成,但我希望能够定义订阅回调函数每个调用,因为我需要对 process
的引用。关于如何解决这个问题有什么想法吗?
最佳答案
应避免使用 for
循环发出多个 HTTP 请求,然后分别订阅所有请求,以免打开许多 Observable
连接。
正如@Juan Mendes 提到的,Observable.forkJoin
将返回一个任务数组,这些任务与进程数组中每个进程的索引相匹配。您还可以在任务到达时将任务分配给每个进程,如下所示:
getTasksForEachProcess(): Observable<any> {
let tasksObservables = this.processes.map(process, processIdx) => {
return myService.getTasks(process)
.map(tasks => {
this.processes[processIdx].tasks = tasks; // assign tasks to each process as they arrive
return tasks;
})
.catch((error: any) => {
console.error('Error loading tasks for process: ' + process, 'Error: ', error);
return Observable.of(null); // In case error occurs, we need to return Observable, so the stream can continue
});
});
return Observable.forkJoin(tasksObservables);
};
this.getTasksForEachProcess().subscribe(
tasksArray => {
console.log(tasksArray); // [[Task], [Task], [Task]];
// In case error occurred e.g. for the process at position 1,
// Output will be: [[Task], null, [Task]];
// If you want to assign tasks to each process after all calls are finished:
tasksArray.forEach((tasks, i) => this.processes[i].tasks = tasksArray[i]);
}
);
关于javascript - Observable.forkJoin 与 for 循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42334469/
调用 forkJoin 时: forkJoin(observableA, observableB) .pipe(takeUntil(onDestroy$)) .pipe(takeUntil(onD
我有以下代码 const mySource:Observable[]> (...) mySource.pipe( switchMap(arr=>forkJoin(arr)); ) 按预期工作,但
TL; 博士 是否可以在 observable 的管道内使用 forkJoin? 完整故事: 我有一个返回对象数组的 Observable 的服务。对于这些对象中的每一个,我都需要再次调用返回一个可观
今天,我打开我的 Angular 项目,发现一个警告说: forkJoin is deprecated: resultSelector is deprecated, pipe to map inste
我正在尝试 Java ForkJoin 框架并编写了一个简单的测试程序,将图像的像素设置为随机颜色。例如。它会产生伪噪声。 但是在测试性能时,我发现运行单线程实际上比运行多线程更快。我通过通过一个高阈
我有一个方法。 private getData() { console.log('Begin'); const sub1 = this.http['url1'].get();
我有几种形式的方法 getFirstDataBunch() { return this.repository.getData(this.parameter).pipe(
我正在使用 forkJoin 合并两个 Firebase 请求的结果 两个请求都完成并记录在控制台中,但 forkJoin 本身的映射函数不会触发,因此没有结果返回到应用程序 public initG
stackblitz 在下面的代码中,this.form.valueChanges 和 this.form.get('name').valueChanges 发射正常。但是 forkJoin 这些都不
我不明白为什么我可以这样做 ForkJoin(service.Obs1(), service.Obs2()).subscribe 但是如果我重构我的代码,以便我向我的服务类添加一个返回 ForkJoi
我的应用程序将进行多个并行 http 调用。它基于 switch-fall though 逻辑,因此查询的数量会有所不同(1、2 或 3 次调用)。有没有办法让我知道哪个电话首先返回?即要么分配一个
我正在尝试使用 forkJoin 运算符来组合两个可观察值并输出一个新值。其中一个调用返回一组对象,其中包含与保单上的多个人相关的数据(该部分不能更改)。另一个 observable 告诉我们谁登录了
对于那里的 Angular 专业人士来说,这应该是一个简单的问题。我有这个简单的方法: private addMultiple(products: Product[]): void { let
我刚刚下载了 Reactive Extensions for .NET 的稳定版本,正在查看 101 Rx examples .并行执行示例使用 ForkJoin方法。这种方法不是稳定版本(或不稳定版
我正在尝试使用 forkJoin 来运行一个带有键和值的对象数组,该值是可观察的。我需要将它设置为对象数组将导致键相同且值是 observable api 调用的结果的位置。这个对象可以有任意数量的键
什么会导致单个 subscribe 触发,但 forkJoin 不触发? 我已经发送了一个触发 subject.subscribe 的请求,但是当我将其添加到与 forkJoin 一起使用的数组时,f
我尝试通过 rx-http-request 使用 RxJS 从 NodeJS 服务器查询第三方 API。从长远来看,我想使用 RxJS 来处理一些更有趣的错误情况。但目前我在运行一个相当微不足道的案例
我目前正在使用 combineLatest() 方法来获取我所有的 friend 并将其作为列表。但是,当我尝试从头开始删除某个项目时,它会产生排序问题。 ( View 无法正确渲染)因此,我想从 c
我有一个使用 Firebase Storage 发送一些图像数据的应用程序,因此我使用此方法: startUpload() { if (typeof this.fileList !== 'unde
我有一个非常大的有序可观察对象列表,需要并行运行。当每个可观察对象返回时,它们将结果附加到行为主题,这就是结果传递的方式。但是,我需要在它们全部完成时调用一个特定的函数。 每个 observables
我是一名优秀的程序员,十分优秀!