カスタムシンクのマテリアライズド・バリューを保持するにはどうすればよいですか？

Question

Future[Int]をこのようにして保存する方法を教えてください。

val test: Sink[Int, NotUsed] = 
    MergeHub.source[Int].grouped(100).to(Sink.fold(0L) { case (count, items) => count + items.sum }).run() 

Sink[Int, Future[Int]]を取得したいと思います。私はviaMat、toMatを見て、それを理解できませんでした。

Answer 1

あなたが同じ場所にグラフ全体をrun()したい場合は、ちょうどあなたがあなたの「グループ+倍」シンクを再利用する必要がある場合は、あなたがソースを取り除く必要があるtoMat + Keep.right

val result: Future[Int] = 
    MergeHub.source[Int].grouped(100).toMat(Sink.fold(0) { case (count, items) => count + items.sum })(Keep.right).run() 

を使用し、 runコール

docsで

val sink: Sink[Int, Future[Int]] = 
    Flow[Int].grouped(100).toMat(Sink.fold(0) { case (count, items) => count + items.sum })(Keep.right) 

詳細情報。