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

Question

我正在尝试在 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实现并行化的正确方式是什么？

Answer 1

map creates a single stream, but parallel 需要 流 .

参见 examples，第二个显示 parallel 的实际效果。您可以尝试修改 t=>t*2 函数以在单元素流中提供其结果：

t=>highland([x*2])

但这只是我的一个想法，我不能尝试。