akkaストリームtoMat

Question

akkaストリーミングでtoMatは何を理解しようとしています。たとえば：

val sink1:Sink[Int, Future[Int]]=Sink.fold[Int,Int](0)(_ + _) 

val flow=Flow[Int].fold[Int](0){(x,y)=> x+y} 

val runnable = Source (1 to 10).viaMat(flow)(Keep.right).toMat(sink1)(Keep.both) 

1. を介した対viaMatの使用は何ですか？
2. viaMatとtoMatの間にtoMatは何をしていますか？
3. keep.bothの使い方は、以前のものと現在のものとの間に価値があることを意味しますか？はいの場合、それらの値をどのように戻すことができますか？

おかげ アルン

Answer 1

1. 経由でviaMat（...）（Keep.left）のためだけのショートカットで、実際に、これはそれが実現しています方法です：override def via[T, Mat2](flow: Graph[FlowShape[Out, T], Mat2]): Repr[T] = viaMat(flow)(Keep.left)

2. toMat viaMatと同じですがシンクの場合は、左側（ソース/フロー）または右側（シンク）側または両方からマテリアライズされた値を保持できます。

3. Keep.bothはちょうど(a:A,b:B) => (a, b)の2つの入力パラメータをタプルとして返す関数です。私は、コードのあなたのラインを切り裂くます

二つの流れ合成する際、左右両側のマテリアライズド値を持っている（またはソースをして流れたり流れ、などシンク）するために使用されます：

// you're keeping the materialized value of flow 
val source2 = Source (1 to 10).viaMat(flow)(Keep.right) 
// you're keeping both materialized values, i.e. the one of flow from previous step 
// and the one o sink.  
val runnableGraph = source2.toMat(sink)(Keep.both) 
runnableGraph.run() // returns a tuple (flowMatVal, sinkMatVal) 

フローの2つの部分（つまり、ソースとフロー/シンク、フローとシンク）を結合すると、フローの実行時に得られるマテリアライズされた値がそれぞれの値になります。 via/toと組み合わせるときのデフォルトの動作は、左側を維持しています。 viaMat/toMatを使用する場合、正しいマテリアライズされた値を保持するか、または両方をタプルとして保持するかを選択できます。

Answer 2

私はそれはヴァル実行可能（マットの両方を維持する）は、次のよう返す必要がありますアッカ・ユーザーグループ

https://groups.google.com/forum/#!topic/akka-user/Ofnx_XzWrTU