akka流toMat

Question

我想了解什麼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的VS通過？
2. Mat在viaMat和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. 托馬特與viaMat相同，但是對於接收器，它允許您從左側（源/流）或右側（接收器）側或兩者都保留物化值。Keep.both只是一個al對於(a:A,b:B) => (a, b)，這是一個函數，它接受兩個輸入參數並將它們作爲元組返回。它被用來將兩個流時，有左邊和右邊兩者的物化價值（或源和流動或流動，水池等）

我會仔細分析你的代碼行：

// 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) 

當您加入流的兩個部分（即源和流/匯或流和匯）時，它們中的每一個都具有您在運行流時獲得的物化值。與via/to結合使用時的默認行爲是保持左側。如果你使用viaMat/toMat，你可以選擇保留正確的物化值或兩者都是元組。

Answer 2

一些細節，我可以能夠從阿卡用戶羣獲得

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