Akka-stream、いくつかのアイテムを受け取ったらトリガーアクション？

Question

私はakka-streamsの "aggregator"ブロックを探しています。たとえば、3つの文字列を受け取ってからアクションをトリガーする（平均長さを評価するなど）まで待ち、アクションの結果を下流に伝播するブロック。

フローは3つの文字列を受け取るために待って、

"hallo" 
"boat" 
"cat" 

を言って、その後

4 

平均の長さを評価し、下流に送信します。これを達成する最も簡単な方法は何ですか？

Answer 1

それは要件ではなく、あなたが同様.scanを使用して、この変化を行うことができます

Source(List(1, 2, 3, 4, 5, 6, 7)) 
    .grouped(3) 
    .map { chunk => 
    chunk.sum/3.0 
    } 

を行うことができ、あなたの特定のケースに依存します。