小编ASe*_*ASe的帖子

我试图了解在akka流媒体中做什么.例如:

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？
2. 什么是toMat在viaMat到toMat之间做什么？
3. 什么是keep.both的用途,是否意味着我可以从之前和当前的一个实现价值,如果是,那么我如何能够获得这些价值.

谢谢阿伦