Akkaストリームで平行なflatMapConcatを実行する方法

Question

mapAsyncのようにストリームの一部を並列化したいが、未来はない。

現在のところ、以下の解決策がありますが、これにはプレーンなflatMapConcatがないマテリアライザーが必要です。

def flatMapConcatParallel[In, Out](parallelism: Int)(f: In => Source[Out, _])(implicit mat: Materializer): Flow[In, Out, NotUsed] = { 
    // TODO there should be a better way to add parallelism that avoids a run (and the need for a materializer) 
    Flow[In].mapAsync(parallelism){i => 
     f(i).runWith(Sink.head) 
    } 
    } 

と

if (parallel){ 
    val parallelism = 4 
    Flow[Batch].via(flatMapConcatParallel(parallelism)(singleRun)) 
} else{ 
    Flow[Batch].flatMapConcat(singleRun) 
} 

これは低レベル（GraphStageLogic）を移動することなく、既存の構造で実現することができる方法上の任意のヒント？

何について

      ---> f() ---> 
--d-c-b-a--> OrderedBalance ---> f() ---> OrderedMerge --d'-c'-b'-a'---> 
          ---> f() ---> 

Answer 1

：なぜ私はこれを自分自身を思い付くしていない

Flow[In].mapAsync(parallelism)(i => Future.successful(f(i))).flatMapConcat(identity)