Я пытаюсь понять, что делает toMat в потоке 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)
- Что такое использование viaMat vs через?
- что делает toMat между viaMat и toMat?
- что используется keep.both, означает ли это, что я могу иметь значение, материализованное из предыдущего и текущего, если да, то как я могу вернуть эти значения.
Спасибо Арун