scala - Keep in akka 流是什么意思？

Question

我正在学习 akka 流，在代码中遇到了 Keep.left 和 Keep.right:

implicit val system = ActorSystem("KafkaProducer")
implicit val materializer = ActorMaterializer()

val source = Source(List("a", "b", "c"))
val sink = Sink.fold[String, String]("")(_ + _)

val runnable: RunnableGraph[Future[String]] = source.toMat(sink)(Keep.right)
val result: Future[String] = runnable.run()

这里的 Keep.right 是什么意思？

Answer 1

每个流处理阶段都可以产生一个物化值，可以使用 viaMat 捕获该值。或 toMat (分别与 via() 或 to() 相对)。在您的代码片段中，使用 source.toMat(sink)表示您有兴趣捕获源和接收器的物化值和 Keep.right保持物化值的右侧(即汇)。 Keep.left将物化值保留在左侧(即源)，和 Keep.both将允许您保留两者。

更多详细信息可在 Akka Streams documentation 中的相关部分获得。 .