Так скзаать for the record в итоге проблема решилась после прочтения https://docs.scala-lang.org/tour/operators.html блок Precedence

Всем привет!

Я делаю расширение коллекций, чтобы синхронно получить результат после выполнения функции в несколько потоков. Основная цель - удобным способом избавиться от параллельных коллекций без доп. зависимостей. Вот что получилось с помощью SO (Duration.Inf на период PoC, по готовности заменю конечным временем) :
https://scastie.scala-lang.org/AV38JUA4QHS2dJh1k1Dbeg

Проблема в том, что это расширение не применимо к Array, а именно Array часто используется в приложении. Что лучше сделать и как сделать:
- переписать класс, чтобы компилятор смог генерализовать в том числе и Array,
- или заменить там, где это нужно, Array на другой тип коллекций (скорее всего List), и, если так, то какой тип лучше выбрать (может Vector заметно производительнее)? Scala 2.11.8

Метод seq вы реализовали сами вместо библиотечного Future.traverse, потому что принципиально важно иметь ограничение в N потоков?

А, у него сигнатура другая

Да, ограничение очень важно

А ограничение на 11 скалу тоже?

в хадуп другую не завезли(

в хадупе вродь никакой не было

или у вас по нодам руками 11ая раскидана?

CDP7, всё, что есть, уже на нодах

Если честно, я бы сделал так https://scastie.scala-lang.org/Odomontois/sw6tqs1YRAG4jldcoGbpwg/2

Или даже так
https://scastie.scala-lang.org/Odomontois/sw6tqs1YRAG4jldcoGbpwg/3

Спасибо, выглядит элегантно. akka в зависимостях немного настораживает, но кто я, чтобы возражать))

Зависит от того, нужно ли вам будет ещё что-то, кроме параллельного мэпа

В текущей постановке можно ваше решение оставить, но с ростом сложности стримы всё равно победят и в лаконичности и в производительности

скорее всего

Скомпилировалось, тесты прошли, собралось, джарник теперь двадцать мегабайт в зипе))

А был

был 9