阿卡河托马特

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 vs via有什么用

谢谢你，阿伦

Answer 1

我可以从akka用户组中得到一些细节

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

Answer 2

>

via只是通往viaMat的捷径（…）（Keep.left），事实上这就是它的实现方式：override def via[T，Mat2]（flow:Graph[FlowShape[Out，T，Mat2]）：Repr[T]=viaMat（flow）（Keep.left）

toMat与viaMat相同，但对于接收器，它允许您从左侧（源/流）或右侧（接收器）或两者保留物化值

Keep.both只是（a： A， b： 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，则可以选择保留正确的物化值，或者将它们作为元组。