如何在流编程中使用Highland.js的parallel()实现并行化?

用户6536429

我正在尝试在 nodejs 中实现流的并行化,以下代码在管道中添加并行方法时终止。

let x = [1,2,3,4,5] highland(x) .map(t => t*2) .parallel(2) .each(t => console.log(t)) .done(()=> console.log('DONE'))

错误 :

Uncaught Error: Expected Stream, got number

使用 highlandjs 实现并行化的正确方法是什么?

特维马达

map创建单个流,但parallel需要一个流流

参见示例,第二个显示parallel在行动中。您可以尝试修改该t=>t*2函数以在单元素流中提供其结果:

t=>highland([x*2])

但这只是我头脑中的一个想法,我无法尝试。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

如何在JS中使用流

使用GNU Parallel并行化嵌套循环

使用GNU parallel并行化bash for循环

如何在bash中使用多个菜单实现DRY编程

如何在pyspark结构化流中使用maxOffsetsPerTrigger?

如何在Spark结构化流中使用流数据帧更新静态数据帧

如何在Akka流中使用值来实例化GooglePubSub流?

使用highland.js在消费流之前做点什么

如何使用GNU-parallel并行化csh while循环并行

如何在Apache Flink中使用流实现LEFT OUTER JOIN

如何在PHP中使用Azure Blob存储实现视频流/分块编码?

如何在Kafka Direct Stream中使用Spark结构化流?

如何在C#中使用流序列化对象

如何在Kafka connect 0.10和Spark结构化流中使用from_json?

如何在张量流中使用张量初始化变量?

如何在SSIS数据流任务中使用格式化文件?

如何实现并行,延迟的方式,使得当输出低于阈值时,并行化的for循环停止?

如何在Node.js中使用pdflatex子进程将PDF作为流获取?

如何在 RX.js 中使用另一个流中的参数?

如何在python或node.js编程语言中使用AWS CLI?

如何使用 `omp parallel` 或其他方式并行化 for 循环?

如何每秒将Highland.js或Node.js流限制到一个对象?

如何在Angular 8中使用angular-oauth2-oidc实现身份验证代码流

如何在Python中使用MPI在不同的内核上实现简单的并行计算

使用highland.js参照原始流数据依次执行异步任务

如何在react Js中使用map实现嵌套循环

如何在页面加载中使用并行?

如何在并行foreach中使用await?

如何在Java中安全地使用并行流?