Как создать материализованную ценность с помощью источника?

Я пытаюсь создать материализованное значение, когда создаю источник следующим образом:

case class Info(value: String)
val source: Source[String, Future[Info]] = Source.single("Start")

Но это не работает. Как создать источник с материализованной ценностью?


scala akka-stream
person softshipper    schedule 13.04.2019    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Вы можете использовать mapMaterializedValue?

val source: Source[String, Future[Info]] = Source.single("Start")
  .mapMaterializedValue(_ => Future(Info("abc")))
person Dmytro Mitin    schedule 13.04.2019