scala – Akka-streams – 如何将flatMapConcatenated的source的

发布时间：2020-12-16 08:45:21 所属栏目：安全来源：网络整理

导读：我试图从Future [Source [Out,Mat]]创建一个Source [Out,Mat],并使用内置的source.fromFuture与flatMapConcat结合使用.但是,当使用fromFuture时,源的实现值为NotUsed.当flatMap与实际源相关联时,实现值保持不被使用. 是否可以获取flatMapConcat中使用的源的

我试图从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)
}

解决方法

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!