Akka-streams-如何访问流的物化值

Question

我正在学习与Akka溪流一起工作，并且真的很喜欢它，但是物化部分对我来说仍然有些神秘。

引用自http://doc.akka.io/docs/akka-stream-and-http-experimental/snapshot/scala/http/client-side/host-level.html#host-level-api

...通过对池客户端流具体化到的HostConnectionPool实例调用shutdown（）来触发特定池的立即关闭

如何获取HostConnectionPool实例？

更重要的是，我想了解一般情况下如何访问物化值并执行某些操作或从中检索信息。

感谢预先提供的任何文档、指针或解释。

Answer 1

这是通过source.viamat函数实现的。从问题中提供的链接扩展代码示例：

import akka.http.scaladsl.Http.HostConnectionPool
import akka.stream.scaladsl.Keep
import akka.stream.scaladsl.RunnableGraph

val poolClientFlow = Http().cachedHostConnectionPool[Int]("akka.io")

val graph: RunnableGraph[(HostConnectionPool, Future[(Try[HttpResponse], Int)])]  =
  Source.single(HttpRequest(uri = "/") -> 42)
        .viaMat(poolClientFlow)(Keep.right)
        .toMat(Sink.head)(Keep.both)

val (pool, fut) = graph.run()

pool.shutdown()

由于source.single具体化为unit，keep.right表示保留poolClientFlow具体化为的hostconnectionpool。在.tomat函数中，keep.both表示将左边的池与flow保持距离，将右边的future与sink保持距离。