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