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 函数完成的。从您的问题中提供的link 扩展代码示例：

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 表示要使左侧池与流保持一致，而右侧 Future 则与Sink 保持一致。