Как использовать параллельный () Highland.js в потоковом программировании для достижения распараллеливания?

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 создает отдельный поток, но parallel ожидает поток потоков .

См. примеры, второй показывает parallel в действии.Вы можете попытаться изменить эту функцию t=>t*2, чтобы обеспечить ее результат в одноэлементном потоке:

t=>highland([x*2])

, но это всего лишь идея из головы, я не могу попробовать.