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

Question

我正在学习使用Akka Streams，非常喜欢它，但材料化部分仍然有些神秘。

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

... 通过调用HostConnectionPool实例上的shutdown()方法来立即关闭特定池

如何获得HostConnectionPool实例？

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

提前感谢任何文档指针或解释。

- Yardena

---

这可能是你问题的解决方案： https://dev59.com/AVoV5IYBdhLWcg3wVNeZ#36467193它基于这里的讨论： https://github.com/akka/akka/issues/17769#issuecomment-206532674 - ncreep

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表示保留流的左侧池和Sink的右侧Future。

- Ramón J Romero y Vigil

---

非常感谢您的回答，toMat()(Keep.both)确实很有帮助。但是如果我想在代码中不同的位置访问池，该怎么办呢？做类似这样的事情是否有意义：Source.empty.viaMat(poolClientFlow)(Keep.right).to(Sink.ignore).run()只是为了获得对池的访问权限？我猜在一般情况下，每个流都可以被实例化为一个不同的实例，但在这里，它是同一个共享池... - Yardena

@Yardena 没关系。我从未尝试在流的上下文之外访问材料化池。要做到这一点，看起来您可以使用与 Http.newHostConnectionPool 设置相同的设置调用 HostConnectionPool 构造函数。这应该返回相同的实例，但我不想将其放在我的答案中，因为我以前从未尝试过。祝你愉快地编程。 - Ramón J Romero y Vigil

再次感谢，我想我会坚持使用Http().shutdownAllConnectionPools()。 - Yardena