我刚刚开始使用akka流,所以这可能是一个微不足道的问题,但我还没有找到答案。
我有一个类型为[String,Something]的输入流,我需要摆脱辅助数据并获取Source [String,NotUsed]。
我怎样才能做到这一点?
谢谢。
一些示例代码:
def f():Source[String, NotUsed] = {
val s=Source[String, Subscriber[String]] = Source.asSubscriber[String]
... // connect the source to a graph
val o=??? //map s to Source[String,NotUsed]
o
}
尝试
val o: Source[String, NotUsed] = s.mapMaterializedValue(_ => NotUsed)
要么
implicit val materializer: ActorMaterializer = ActorMaterializer()
val o: Source[String, NotUsed] = s.preMaterialize()._2