Akka-streams - 如何将 flatMapConcatenated 源的物化值获取到另一个源？

Question

我正在尝试从 Future[Source[Out,Mat]] 创建 Source[Out,Mat] 并结合使用内置的 source.fromFuture 和 flatMapConcat。但是，当使用 fromFuture 时，源具有 NotUsed 的物化值。 flatMap拼接实际源时，物化值一直未被使用

是否可以获取在 flatMapConcat 中使用的源的物化值？

代码如下所示：

def sourceFromFutureSource[Out,Mat](futureSource: Future[Source[Out,Mat]]): Source[Out, Mat] = {
Source.fromFuture(futureSource)
  .flatMapConcat(identity)
}

Answer 1

从 Akka 2.5.1 开始可以使用 Source.fromFutureSource。现在你可以做 Source.fromFutureSource(futureSource).

Akka-streams - 如何将 flatMapConcatenated 源的物化值获取到另一个源？

Akka-streams - How to take the materialized value of source which is flatMapConcatenated in to another source?

scala

akka-stream