Отображение источника потока akka [A, B] на источник [A, NotUsed]

Question

Я только начал использовать потоки akka, так что это может быть тривиальным вопросом, однако я не нашел ответа на него.

У меня есть входной поток с типом [String, Something], и мне нужно избавиться от вспомогательных данных и получить источник [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
}

Answer 1

Попробуйте

val o: Source[String, NotUsed] = s.mapMaterializedValue(_ => NotUsed)

или

implicit val materializer: ActorMaterializer = ActorMaterializer()
val o: Source[String, NotUsed] = s.preMaterialize()._2